Offer values for waiting futures
Offer values for waiting futures
Offer a value for waiting futures
Offer a value for waiting futures
size of offer queue
a future that completes once input is available
a future that completes once input is available
size of polling queue
An implementation of ConcurrentQueue using a ListBuffer backend TODO: explore using a true "concurrent" back end collection that avoids locking TODO: (http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html)