Class Thread

src/ThreadPool.h:73–154

};

class Thread {
  static const int WAIT_USECONDS = 50000;
  typedef void* (*wrapper_t)(void*);

public:
  Thread(void* (*wrapper)(void*), ThreadArg* arg, bool delete_arg, unsigned int num) : wrapper(wrapper), arg(arg), delete_arg(delete_arg), num(num) {
	state = NOT_STARTED;
	tid = 0;
	memset(&tv_started, 0, sizeof(tv_started));
	memset(&tv_finished, 0, sizeof(tv_finished));
	pthread_mutex_init(&mp, NULL);
  }

  void running() {
	pthread_mutex_lock(&mp);
	gettimeofday(&tv_started, NULL);
	state = RUNNING;
	tid = pthread_self();
	pthread_mutex_unlock(&mp);
  }

  void finished() {
	pthread_mutex_lock(&mp);
	gettimeofday(&tv_finished, NULL);
	state = FINISHED;
	pthread_mutex_unlock(&mp);
  }

  bool waitFinished() {


   #ifdef _WIN32
//x32 Windows definitions
	Sleep(WAIT_USECONDS);
#else
//other platforms
	usleep(WAIT_USECONDS);
#endif

	usleep(WAIT_USECONDS);
	pthread_mutex_lock(&mp);
	if (state == FINISHED) {
	  pthread_mutex_unlock(&mp);
	  return true;
	}
	pthread_mutex_unlock(&mp);
	return false;
  }

  unsigned int getNumber() const {return num;}
  pthread_t getThreadSelf() const {return tid;}

  long long duration() const {
	pthread_mutex_lock(&mp);
	long long tv_usec = (state == FINISHED ? (unsigned long long)(tv_finished.tv_sec - tv_started.tv_sec) * 1000000 + (tv_finished.tv_usec - tv_started.tv_usec) : -1);
	pthread_mutex_unlock(&mp);
	return tv_usec;
  }