summaryrefslogtreecommitdiff
path: root/examples/Threads
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-03-18 03:42:27 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-03-18 03:42:27 +0000
commitb6a57c3a0102e5dd3fd1dffa4b4438701e831156 (patch)
tree443cb0ef3188a1ddb6e17b849662a663db6b2f31 /examples/Threads
parent4a656d918f4e20367c2af7721e1a3ad74ad83ab9 (diff)
downloadATCD-b6a57c3a0102e5dd3fd1dffa4b4438701e831156.tar.gz
(svc): use ACE_OS::sleep instead of ::Sleep. (main): declare "ii"
outside of the first loop because it is used in other loops.
Diffstat (limited to 'examples/Threads')
-rw-r--r--examples/Threads/task_five.cpp68
1 files changed, 35 insertions, 33 deletions
diff --git a/examples/Threads/task_five.cpp b/examples/Threads/task_five.cpp
index 996932bec0c..5c2141eeece 100644
--- a/examples/Threads/task_five.cpp
+++ b/examples/Threads/task_five.cpp
@@ -36,9 +36,10 @@ int
TestTask::svc (void)
{
while (!thr_mgr_->testcancel(ACE_OS::thr_self()))
- {
- ::Sleep(350);
- }
+ {
+ ACE_Time_Value sleep_time (0, 350000);
+ ACE_OS::sleep (sleep_time);
+ }
return 0;
}
@@ -63,57 +64,58 @@ TestTask::synch (void)
int
main (int, char *[])
{
- const int numTasks = 1000;
- unsigned int loopCnt = 0;
- unsigned int errCnt = 0;
+ const int numTasks = 1000;
+ unsigned int loopCnt = 0;
+ unsigned int errCnt = 0;
ACE_Thread_Manager *thr_mgr = ACE_Service_Config::thr_mgr ();
- TestTask *TaskArrPtr;
+ TestTask *TaskArrPtr;
while (1)
{
- TaskArrPtr = new TestTask[numTasks];
+ int ii;
+ TaskArrPtr = new TestTask[numTasks];
- cout << "Opening Tasks!" << loopCnt
+ cout << "Opening Tasks!" << loopCnt
<< " " << errCnt << endl;
- for (int ii =0; ii < numTasks; ii++)
- {
- TaskArrPtr[ii].open();
- }
+ for (ii =0; ii < numTasks; ii++)
+ {
+ TaskArrPtr[ii].open();
+ }
- ACE_OS::sleep (1);
+ ACE_OS::sleep (1);
- cout << "Cancelling Tasks!" << loopCnt
+ cout << "Cancelling Tasks!" << loopCnt
<< " " << errCnt << endl;
- for (ii = 0; ii < numTasks; ii++)
- {
- TaskArrPtr[ii].shutdownRq();
- }
+ for (ii = 0; ii < numTasks; ii++)
+ {
+ TaskArrPtr[ii].shutdownRq();
+ }
- cout << "Synching Tasks!" << loopCnt
+ cout << "Synching Tasks!" << loopCnt
<< " " << errCnt << endl;
- for (ii = 0; ii < numTasks; ii++)
- {
- if (-1 == TaskArrPtr[ii].synch())
- {
- cout << "Error in synch! " << loopCnt
+ for (ii = 0; ii < numTasks; ii++)
+ {
+ if (-1 == TaskArrPtr[ii].synch())
+ {
+ cout << "Error in synch! " << loopCnt
<< " " << errCnt << " " << ii << endl;
- errCnt++;
- }
- }
+ errCnt++;
+ }
+ }
- cout << "thr_mgr->wait ();!" << loopCnt
+ cout << "thr_mgr->wait ();!" << loopCnt
<< " " << errCnt << endl;
- thr_mgr->wait ();
-
- delete [] TaskArrPtr;
+ thr_mgr->wait ();
- loopCnt++;
+ delete [] TaskArrPtr;
+
+ loopCnt++;
}