summaryrefslogtreecommitdiff
path: root/cpp/lib/common/sys/ThreadSafeQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/common/sys/ThreadSafeQueue.h')
-rw-r--r--cpp/lib/common/sys/ThreadSafeQueue.h8
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(); }