test_threadserver.cpp

// Copyright (C) 2009-2010 Institut de Robòtica i Informàtica Industrial, CSIC-UPC.
// Author Sergi Hernandez  (shernand@iri.upc.edu)
// All rights reserved.
//
// This file is part of iriutils
// iriutils is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

#include "threadserver.h"
#include "threadexceptions.h"
#include <stdio.h>
#include <unistd.h>
#include <iostream>

const std::string thread1="thread_1";
const std::string thread2="thread_2";

const std::string thread3="invalid_thread";

void *my_thread_function1(void *param)
{
  int i=0;

  while(1)
  {
    std::cout << "thread 1 loop " << i << std::endl;
    i++;
    sleep(1);
  }  
  pthread_exit(NULL);
}

void *my_thread_function2(void *param)
{
  int i=0;

  for(i=0;i<15;i++)
  {
    std::cout << "thread 2 loop " << i << std::endl;
    sleep(1);
  }

  pthread_exit(NULL);
}

int main(int argc, char *argv[])
{
  CThreadServer *thread_server;

  thread_server=CThreadServer::instance();

  thread_server->create_thread(thread1);
  thread_server->create_thread(thread2);

  thread_server->attach_thread(thread1,my_thread_function1,NULL);
  thread_server->attach_thread(thread2,my_thread_function2,NULL);

  thread_server->start_thread(thread1);
  sleep(2);
  thread_server->start_thread(thread2);
  thread_server->end_thread(thread2);
  thread_server->kill_thread(thread1);

  thread_server->detach_thread(thread1);
  try{
    thread_server->start_thread(thread1);
  }catch(CThreadException &e){
    std::cout << e.what() << std::endl;
  }
  
  thread_server->delete_thread(thread1);
  thread_server->delete_thread(thread2);

  try{
    thread_server->attach_thread(thread3,my_thread_function2,NULL);
  }catch(CThreadServerException &e){
    std::cout << e.what() << std::endl;
  }
}