summaryrefslogtreecommitdiff
path: root/cpp/demo/IceUtil/workqueue/WorkQueue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/demo/IceUtil/workqueue/WorkQueue.cpp')
-rw-r--r--cpp/demo/IceUtil/workqueue/WorkQueue.cpp11
1 files changed, 3 insertions, 8 deletions
diff --git a/cpp/demo/IceUtil/workqueue/WorkQueue.cpp b/cpp/demo/IceUtil/workqueue/WorkQueue.cpp
index 8d455d817ea..f3e343c14a1 100644
--- a/cpp/demo/IceUtil/workqueue/WorkQueue.cpp
+++ b/cpp/demo/IceUtil/workqueue/WorkQueue.cpp
@@ -53,14 +53,9 @@ public:
virtual void
run()
{
- while(1)
+ string item;
+ while((item = nextItem()) != "destroy")
{
- string item = nextItem();
- if(item == "destroy")
- {
- break;
- }
-
mtprint("work item: " + item + "\n");
IceUtil::ThreadControl::sleep(IceUtil::Time::seconds(1));
}
@@ -87,7 +82,7 @@ private:
{
_monitor.wait();
}
-
+
string item = _queue.front();
_queue.pop_front();
return item;