diff options
Diffstat (limited to 'cpp/lib/common/sys/ThreadSafeQueue.h')
-rw-r--r-- | cpp/lib/common/sys/ThreadSafeQueue.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/lib/common/sys/ThreadSafeQueue.h b/cpp/lib/common/sys/ThreadSafeQueue.h index ff949a3e16..80ea92da0e 100644 --- a/cpp/lib/common/sys/ThreadSafeQueue.h +++ b/cpp/lib/common/sys/ThreadSafeQueue.h @@ -46,7 +46,7 @@ class ThreadSafeQueue } /** Pop a value from the front of the queue. Waits till value is available. - *@throw ShutdownException if queue is stopped while waiting. + *@throw ShutdownException if queue is shutdown while waiting. */ T pop() { ProducerConsumer::ConsumerLock consumer(pc); @@ -75,10 +75,10 @@ class ThreadSafeQueue } /** Interrupt threads waiting in pop() */ - void stop() { pc.stop(); } + void shutdown() { pc.shutdown(); } - /** True if queue is stopped */ - bool isStopped() { return pc.isStopped(); } + /** True if queue is shutdown */ + bool isShutdown() { return pc.isShutdown(); } /** Size of the queue */ size_t size() { ProducerConsumer::Lock l(pc); return container.size(); } |