Function team_work

example/multi_thread/bthread/team_bthread.cpp:173–206

}

bool team_work(void worker(void))
{
   // 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;
   ok     &= wait_for_work_  != nullptr;
   ok     &= wait_for_job_   != nullptr;

   // 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 when master thread calls wait_for_job_
   if( num_threads_ > 1 )
      sequential_execution_ = false;
   wait_for_job_->wait();

   // Now do the work in this thread and then wait
   // until all threads have completed wait_for_work_
   worker();
   wait_for_work_->wait();

   // 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)
{  // Current state is other threads are at wait_for_job_.