Prev

Next

Index-> contents reference index search external

Up-> CppAD multi_thread thread_test.cpp multi_atomic.cpp multi_atomic_common

multi_thread-> parallel_ad thread_test.cpp

thread_test.cpp-> a11c_openmp.cpp a11c_bthread.cpp a11c_pthread.cpp simple_ad_openmp.cpp simple_ad_bthread.cpp simple_ad_pthread.cpp team_example.cpp harmonic.cpp multi_atomic.cpp multi_newton.cpp team_thread.hpp

multi_atomic.cpp-> multi_atomic_user multi_atomic_common multi_atomic_setup multi_atomic_worker multi_atomic_takedown multi_atomic_run multi_atomic_time

multi_atomic_common

Headings-> Purpose Source

namespace {
     // Number of threads, set by multi_atomic_time
     // (zero means one thread with no multi-threading setup)
     size_t num_threads_ = 0;

     // Number of Newton iterations, set by multi_atomic_time
     size_t num_itr_;

     // We can use one atomic_user function for all threads because
     // there is no member data that gets changed during worker call.
     // This needs to stay in scope for as long as a recording will use it.
     // We cannot be in parallel mode when this object is created or deleted.
     // We use a pointer so that there is no left over memory in thread zero.
     atomic_user* a_square_root_ = 0;

     // structure with information for one thread
     typedef struct {
          // used by worker to compute the square root, set by multi_atomic_setup
          CppAD::ADFun<double>* fun;
          //
          // value we are computing square root of, set by multi_atomic_setup
          vector<double>* y_squared;
          //
          // square root, set by worker
          vector<double>* square_root;
          //
          // false if an error occurs, true otherwise, set by worker
          bool ok;
     } work_one_t;
     //
     // Vector with information for all threads
     // (uses pointers instead of values to avoid false sharing)
     // allocated by multi_atomic_setup, freed by multi_atomic_takedown
     work_one_t* work_all_[CPPAD_MAX_NUM_THREADS];
}