test_threads.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 "thread.h"
#include "threadexceptions.h"
#include <stdio.h>
#include <unistd.h>
#include <iostream>


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

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


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

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


void *my_thread_function3(void *param)
{
  int i=0;
  int num_iter=*((int *)param);

  for(i=0;i<=num_iter;i++)
  {
    std::cout << "user defined loop number: " << i << std::endl;
    sleep(1);
  }

  pthread_exit(NULL);
}

int main(int argc, char *argv[])
{
  int num_iter=3;
  std::string thread_id;
  CThread Thread("test_thread"),*Thread2;

  // get the thread identifier
  thread_id=Thread.get_id();
  std::cout << "Thread identifier: " << thread_id << std::endl;
  // test with the first function
  // the expected state is detachhed (3)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.attach(my_thread_function,NULL);
  // the expected state is attached (0)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.start();
  // the expected state is active (2) or starting (1)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  // wait until the thread executes all the iterations
  Thread.end();
  // the expected state is attached (0) 
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.detach();
  // the expected state is detached (3)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;

  // test with the second function
  Thread.attach(my_thread_function2,NULL);
  // the expected state is attached (0)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.start();
  // the expected state is active (2) or starting (1)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  // wait for the thread to execute some loops (15 aprox)
  sleep(3);
  // cancel the thread immediatelly
  Thread.kill();
  // the expected state is attached (0)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;

  // test with the thirth function
  Thread.attach(my_thread_function3,&num_iter);
  // the expected state is attached (0)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.start();
  // the expected state is active (2) or starting (1)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  // wait until the trhead executes num_iter iterations
  Thread.end();
  // the expected state is attached (0)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;
  Thread.detach();
  // the expected state is detached (3)
  std::cout << "Thread state: " << Thread.get_state() << std::endl;

  // test thread exceptions
  try{
    Thread.attach(NULL,NULL);
  }catch(CThreadException &e){
    std::cout << e.what() << std::endl;
  }
  try{
    Thread.start();
  }catch(CThreadException &e){
    std::cout << e.what() << std::endl;
  }
  try{
    Thread2=new CThread("");
    delete Thread2;
  }catch(CThreadException &e){
    std::cout << e.what() << std::endl;
  }
}