diff options
author | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-07-26 20:37:21 +0000 |
---|---|---|
committer | irfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-07-26 20:37:21 +0000 |
commit | 0725903fd35de34a14bf4fc7eb08fbca79443495 (patch) | |
tree | 0db5559c09ddb0ebf5cec31bf897a3804a7f33ef /examples/Threads | |
parent | 9fdd114f9305dd042c03e0a340bb54d6897b4751 (diff) | |
download | ATCD-0725903fd35de34a14bf4fc7eb08fbca79443495.tar.gz |
*** empty log message ***
Diffstat (limited to 'examples/Threads')
-rw-r--r-- | examples/Threads/auto_event.cpp | 6 | ||||
-rw-r--r-- | examples/Threads/barrier1.cpp | 6 | ||||
-rw-r--r-- | examples/Threads/barrier2.cpp | 4 | ||||
-rw-r--r-- | examples/Threads/cancel.cpp | 4 | ||||
-rw-r--r-- | examples/Threads/manual_event.cpp | 4 | ||||
-rw-r--r-- | examples/Threads/process_manager.cpp | 6 | ||||
-rw-r--r-- | examples/Threads/recursive_mutex.cpp | 6 | ||||
-rw-r--r-- | examples/Threads/task_four.cpp | 2 | ||||
-rw-r--r-- | examples/Threads/task_one.cpp | 4 | ||||
-rw-r--r-- | examples/Threads/task_three.cpp | 2 | ||||
-rw-r--r-- | examples/Threads/task_two.cpp | 2 | ||||
-rw-r--r-- | examples/Threads/thread_manager.cpp | 6 | ||||
-rw-r--r-- | examples/Threads/thread_pool.cpp | 4 | ||||
-rw-r--r-- | examples/Threads/thread_specific.cpp | 10 |
14 files changed, 33 insertions, 33 deletions
diff --git a/examples/Threads/auto_event.cpp b/examples/Threads/auto_event.cpp index 77f3cf82ace..77842017675 100644 --- a/examples/Threads/auto_event.cpp +++ b/examples/Threads/auto_event.cpp @@ -30,7 +30,7 @@ reader (void *arg) // Shared data via a reference. int& data = *(int *) arg; - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); // Wait for writer to complete. @@ -54,7 +54,7 @@ writer (void *arg) { int& data = *(int *) arg; - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); // Calculate (work). ACE_DEBUG ((LM_DEBUG, "(%t) writer: working for %d secs\n", work_time)); @@ -85,7 +85,7 @@ main (int argc, char **argv) work_time = argc == 2 ? atoi (argv[1]) : 5; // threads manager - ACE_Thread_Manager& tm = *ACE_Service_Config::thr_mgr (); + ACE_Thread_Manager& tm = *ACE_Thread_Manager::instance (); // Create reader thread. if (tm.spawn (reader, (void *) &data) == -1) diff --git a/examples/Threads/barrier1.cpp b/examples/Threads/barrier1.cpp index 94f39962b55..3800e7cc84d 100644 --- a/examples/Threads/barrier1.cpp +++ b/examples/Threads/barrier1.cpp @@ -33,7 +33,7 @@ static void * tester (Tester_Args *args) { // Keeps track of thread exit. - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); for (int iterations = 1; iterations <= args->n_iterations_; @@ -63,13 +63,13 @@ main (int argc, char *argv[]) Tester_Args args (tester_barrier, n_iterations); - if (ACE_Service_Config::thr_mgr ()->spawn_n + if (ACE_Thread_Manager::instance ()->spawn_n (int(n_threads), ACE_THR_FUNC (tester), (void *) &args, THR_NEW_LWP | THR_DETACHED) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn_n"), 1); // Wait for all the threads to reach their exit point. - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); ACE_DEBUG ((LM_DEBUG, "(%t) done\n")); return 0; diff --git a/examples/Threads/barrier2.cpp b/examples/Threads/barrier2.cpp index 1fe7b2175ac..d917b44d401 100644 --- a/examples/Threads/barrier2.cpp +++ b/examples/Threads/barrier2.cpp @@ -245,14 +245,14 @@ main (int argc, char *argv[]) Worker_Task<BARRIER_TYPE> *worker_task = - new Worker_Task<BARRIER_TYPE> (ACE_Service_Config::thr_mgr (), + new Worker_Task<BARRIER_TYPE> (ACE_Thread_Manager::instance (), /*n_threads*/ 0,0); worker_task->Producer (); // Wait for all the threads to reach their exit point. ACE_DEBUG ((LM_DEBUG,"(%t) waiting with thread manager ...\n")); - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); ACE_DEBUG ((LM_DEBUG,"(%t) delete worker task ...\n")); delete worker_task; diff --git a/examples/Threads/cancel.cpp b/examples/Threads/cancel.cpp index a9d12bea579..919922a8208 100644 --- a/examples/Threads/cancel.cpp +++ b/examples/Threads/cancel.cpp @@ -14,7 +14,7 @@ worker (int iterations) for (int i = 0; i < iterations; i++) { if ((i % 10) == 0 - && (ACE_Service_Config::thr_mgr ()->testcancel (ACE_Thread::self ()) != 0)) + && (ACE_Thread_Manager::instance ()->testcancel (ACE_Thread::self ()) != 0)) { ACE_DEBUG ((LM_DEBUG, "(%t) has been cancelled before iteration!\n", i)); break; @@ -37,7 +37,7 @@ main (int argc, char *argv[]) int n_threads = argc > 1 ? ACE_OS::atoi (argv[1]) : DEFAULT_THREADS; int n_iterations = argc > 2 ? ACE_OS::atoi (argv[2]) : DEFAULT_ITERATIONS; - ACE_Thread_Manager *thr_mgr = ACE_Service_Config::thr_mgr (); + ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); int grp_id = thr_mgr->spawn_n (n_threads, ACE_THR_FUNC (worker), (void *) n_iterations, diff --git a/examples/Threads/manual_event.cpp b/examples/Threads/manual_event.cpp index 65e08920d05..886207e71fe 100644 --- a/examples/Threads/manual_event.cpp +++ b/examples/Threads/manual_event.cpp @@ -56,7 +56,7 @@ Pseudo_Barrier::wait (void) static void * worker (void *arg) { - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); Pseudo_Barrier &barrier = *(Pseudo_Barrier *) arg; // work @@ -81,7 +81,7 @@ main (int argc, char **argv) { int n_threads = argc == 2 ? atoi (argv[1]) : 5; - ACE_Thread_Manager &tm = *ACE_Service_Config::thr_mgr (); + ACE_Thread_Manager &tm = *ACE_Thread_Manager::instance (); // synch object shared by all threads Pseudo_Barrier barrier (n_threads); diff --git a/examples/Threads/process_manager.cpp b/examples/Threads/process_manager.cpp index 9715daa6cb3..ea8d06bb5a8 100644 --- a/examples/Threads/process_manager.cpp +++ b/examples/Threads/process_manager.cpp @@ -14,7 +14,7 @@ static ACE_Process_Manager proc_mgr; void * sig_handler (void *) { - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); ACE_Sig_Set sigset; @@ -137,7 +137,7 @@ main (int argc, char *argv[]) if (ACE_OS::thr_sigsetmask (SIG_BLOCK, sigset, 0) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "thr_sigsetmask"), 1); - else if (ACE_Service_Config::thr_mgr ()->spawn (sig_handler, 0, THR_DETACHED) == -1) + else if (ACE_Thread_Manager::instance ()->spawn (sig_handler, 0, THR_DETACHED) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn"), 1); if (child) @@ -165,7 +165,7 @@ main (int argc, char *argv[]) // Perform a barrier wait until all the processes and threads // have shut down. proc_mgr.wait (); - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); } return 0; diff --git a/examples/Threads/recursive_mutex.cpp b/examples/Threads/recursive_mutex.cpp index 1cc2892b2a8..7525d2bc120 100644 --- a/examples/Threads/recursive_mutex.cpp +++ b/examples/Threads/recursive_mutex.cpp @@ -74,7 +74,7 @@ recursive_worker (size_t nesting_level, static void * worker (void *arg) { - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); ACE_Recursive_Thread_Mutex *rm = (ACE_Recursive_Thread_Mutex *) arg; @@ -90,11 +90,11 @@ main (int argc, char *argv[]) parse_args (argc, argv); ACE_Recursive_Thread_Mutex rm; - ACE_Service_Config::thr_mgr ()->spawn_n (n_threads, + ACE_Thread_Manager::instance ()->spawn_n (n_threads, ACE_THR_FUNC (worker), (void *) &rm); - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); return 0; } #else diff --git a/examples/Threads/task_four.cpp b/examples/Threads/task_four.cpp index 9627606ae8d..3710ff1a827 100644 --- a/examples/Threads/task_four.cpp +++ b/examples/Threads/task_four.cpp @@ -146,7 +146,7 @@ Invoker_Task::svc (void) // Note that the ACE_Task::svc_run () method automatically adds us to // the Thread_Manager when the thread begins. - ACE_Thread_Manager *thr_mgr = ACE_Service_Config::thr_mgr (); + ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); Worker_Task **worker_task; ACE_NEW_RETURN (worker_task, Worker_Task *[n_tasks_], -1); diff --git a/examples/Threads/task_one.cpp b/examples/Threads/task_one.cpp index 7acf8de3789..80c96c67303 100644 --- a/examples/Threads/task_one.cpp +++ b/examples/Threads/task_one.cpp @@ -79,12 +79,12 @@ main (int argc, char *argv[]) int n_threads = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_THREADS; int n_iterations = argc > 2 ? ACE_OS::atoi (argv[2]) : DEFAULT_ITERATIONS; - Barrier_Task barrier_task (ACE_Service_Config::thr_mgr (), + Barrier_Task barrier_task (ACE_Thread_Manager::instance (), n_threads, n_iterations); // Wait for all the threads to reach their exit point. - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); ACE_DEBUG ((LM_DEBUG, "(%t) done\n")); return 0; diff --git a/examples/Threads/task_three.cpp b/examples/Threads/task_three.cpp index bdfae9b0e0b..45ac8106784 100644 --- a/examples/Threads/task_three.cpp +++ b/examples/Threads/task_three.cpp @@ -177,7 +177,7 @@ main (int argc, char **) ACE_Sig_Action sa ((ACE_SignalHandler) handler, SIGINT); ACE_UNUSED_ARG (sa); - ACE_Reactor *reactor1 = ACE_Service_Config::reactor (); + ACE_Reactor *reactor1 = ACE_Reactor::instance(); ACE_Reactor *reactor2 = new ACE_Reactor (); Test_Task t1[TASK_COUNT]; diff --git a/examples/Threads/task_two.cpp b/examples/Threads/task_two.cpp index 9ac9386a171..133d3a69852 100644 --- a/examples/Threads/task_two.cpp +++ b/examples/Threads/task_two.cpp @@ -121,7 +121,7 @@ main (int argc, char *argv[]) i, (int) max_count, (int) wait_count)); // Wait for all the tasks to exit. - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); // Delete the existing tasks. for (int k = 0; k < n_threads; k++) diff --git a/examples/Threads/thread_manager.cpp b/examples/Threads/thread_manager.cpp index 48cd2bb8b04..790b591e650 100644 --- a/examples/Threads/thread_manager.cpp +++ b/examples/Threads/thread_manager.cpp @@ -19,7 +19,7 @@ handler (int signum) static void * worker (int iterations) { - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); for (int i = 0; i < iterations; i++) { @@ -29,7 +29,7 @@ worker (int iterations) "(%t) checking cancellation before iteration %d!\n", i)); - if (ACE_Service_Config::thr_mgr ()->testcancel (ACE_Thread::self ()) != 0) + if (ACE_Thread_Manager::instance ()->testcancel (ACE_Thread::self ()) != 0) { ACE_DEBUG ((LM_DEBUG, "(%t) has been cancelled before iteration %d!\n", @@ -60,7 +60,7 @@ main (int argc, char *argv[]) int n_threads = argc > 1 ? ACE_OS::atoi (argv[1]) : DEFAULT_THREADS; int n_iterations = argc > 2 ? ACE_OS::atoi (argv[2]) : DEFAULT_ITERATIONS; - ACE_Thread_Manager *thr_mgr = ACE_Service_Config::thr_mgr (); + ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); int grp_id = thr_mgr->spawn_n (n_threads, ACE_THR_FUNC (worker), (void *) n_iterations, diff --git a/examples/Threads/thread_pool.cpp b/examples/Threads/thread_pool.cpp index 2cf3a8c61a6..ec103b1bdd3 100644 --- a/examples/Threads/thread_pool.cpp +++ b/examples/Threads/thread_pool.cpp @@ -186,7 +186,7 @@ main (int argc, char *argv[]) argc, n_threads)); // Create the worker tasks. - Thread_Pool thread_pool (ACE_Service_Config::thr_mgr (), + Thread_Pool thread_pool (ACE_Thread_Manager::instance (), n_threads); // Create work for the worker tasks to process in their own threads. @@ -195,7 +195,7 @@ main (int argc, char *argv[]) // Wait for all the threads to reach their exit point. ACE_DEBUG ((LM_DEBUG, "(%t) waiting with thread manager...\n")); - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); ACE_DEBUG ((LM_DEBUG, "(%t) destroying worker tasks and exiting...\n")); return 0; diff --git a/examples/Threads/thread_specific.cpp b/examples/Threads/thread_specific.cpp index fae28199cec..b1c3bc0e895 100644 --- a/examples/Threads/thread_specific.cpp +++ b/examples/Threads/thread_specific.cpp @@ -79,7 +79,7 @@ cleanup (void *ptr) static void * worker (void *c) { - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); int count = int (c); ACE_thread_key_t key = ACE_OS::NULL_key; @@ -170,7 +170,7 @@ extern "C" void handler (int signum) { ACE_DEBUG ((LM_DEBUG, "signal = %S\n", signum)); - ACE_Service_Config::thr_mgr ()->exit (0); + ACE_Thread_Manager::instance ()->exit (0); } int @@ -178,7 +178,7 @@ main (int argc, char *argv[]) { // The Service_Config must be the first object defined in main... ACE_Service_Config daemon (argv[0]); - ACE_Thread_Control tc (ACE_Service_Config::thr_mgr ()); + ACE_Thread_Control tc (ACE_Thread_Manager::instance ()); int threads = argc > 1 ? ACE_OS::atoi (argv[1]) : 4; int count = argc > 2 ? ACE_OS::atoi (argv[2]) : 10000; @@ -187,13 +187,13 @@ main (int argc, char *argv[]) ACE_UNUSED_ARG (sa); #if defined (ACE_HAS_THREADS) - if (ACE_Service_Config::thr_mgr ()->spawn_n (threads, + if (ACE_Thread_Manager::instance ()->spawn_n (threads, ACE_THR_FUNC (&worker), (void *) count, THR_BOUND | THR_DETACHED) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "ACE_Thread_Manager::spawn_n"), -1); - ACE_Service_Config::thr_mgr ()->wait (); + ACE_Thread_Manager::instance ()->wait (); #else worker ((void *) count); #endif /* ACE_HAS_THREADS */ |