Function team_destroy

example/multi_thread/bthread/team_bthread.cpp:208–254

}

bool team_destroy(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 the new job that other threads are waiting for
   thread_job_ = join_enum;

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

   // now wait for the other threads to be destroyed
   size_t thread_num;
   ok &= thread_all_[0].bthread == nullptr;
   for(thread_num = 1; thread_num < num_threads_; thread_num++)
   {  thread_all_[thread_num].bthread->join();
      delete thread_all_[thread_num].bthread;
      thread_all_[thread_num].bthread = nullptr;
   }
   // now we are down to just the master thread (thread zero)
   sequential_execution_ = true;

   // destroy wait_for_work_
   delete wait_for_work_;
   wait_for_work_ = nullptr;

   // destroy wait_for_job_
   delete wait_for_job_;
   wait_for_job_ = nullptr;

   // check ok before changing num_threads_
   for(thread_num = 0; thread_num < num_threads_; thread_num++)
      ok &= thread_all_[thread_num].ok;

   // now inform CppAD that there is only one thread
   num_threads_ = 1;
   thread_alloc::parallel_setup(num_threads_, nullptr, nullptr);
   thread_alloc::hold_memory(false);
   CppAD::parallel_ad<double>();

   return ok;
}

const char* team_name(void)
{  return "bthread"; }