Function team_work

example/multi_thread/pthread/team_pthread.cpp:243–280

}

bool team_work(void worker(void))
{  int rc;

   // Current state is other threads are at wait_for_job_.
   // This master thread (thread zero) has not completed wait_for_job_
   bool ok = sequential_execution_;
   ok     &= thread_number() == 0;

   // set global version of this work routine
   worker_ = worker;


   // set the new job that other threads are waiting for
   thread_job_ = work_enum;

   // enter parallel execution soon as master thread completes wait_for_job_
   if( num_threads_ > 1 )
      sequential_execution_ = false;

   // wait until all threads have completed wait_for_job_
   rc  = pthread_barrier_wait(&wait_for_job_);
   ok &= (rc == 0 || rc == PTHREAD_BARRIER_SERIAL_THREAD);

   // Now do the work in this thread and then wait
   // until all threads have completed wait_for_work_
   worker();
   rc = pthread_barrier_wait(&wait_for_work_);
   ok &= (rc == 0 || rc == PTHREAD_BARRIER_SERIAL_THREAD);

   // Current state is other threads are at wait_for_job_.
   // This master thread (thread zero) has not completed wait_for_job_
   sequential_execution_ = true;

   size_t thread_num;
   for(thread_num = 0; thread_num < num_threads_; thread_num++)
      ok &= thread_all_[thread_num].ok;
   return ok;
}

bool team_destroy(void)
{  int rc;