Function team_destroy

example/multi_thread/pthread/team_pthread.cpp:282–334

}

bool team_destroy(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 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;
   rc  = pthread_barrier_wait(&wait_for_job_);
   ok &= (rc == 0 || rc == PTHREAD_BARRIER_SERIAL_THREAD);

   // now wait for the other threads to exit
   size_t thread_num;
   for(thread_num = 1; thread_num < num_threads_; thread_num++)
   {  void* no_status = nullptr;
      rc      = pthread_join(
         thread_all_[thread_num].pthread_id, &no_status
      );
      ok &= (rc == 0);
   }

   // now we are down to just the master thread (thread zero)
   sequential_execution_ = true;

   // destroy the key for thread specific data
   pthread_key_delete(thread_specific_key_);

   // destroy wait_for_work_
   rc  = pthread_barrier_destroy(&wait_for_work_);
   ok &= (rc == 0);

   // destroy wait_for_job_
   rc  = pthread_barrier_destroy(&wait_for_job_);
   ok &= (rc == 0);

   // 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 "pthread"; }