queue package:core-program

A queue which has an end, someday. (this is a thin wrapper over the stm TQueue type)

Indicate that you are finished adding queue, thereby allowing the worker threads consuming from the queue to complete and return. Remember that you can call at any time, even before you have launched the worker threads with runWorkers_.

Initialize a new queue.

Access the underlying queue. We make use of the STM TQueue type, so you'll want the following imports:

import Control.Concurrent.STM (atomically)
import Control.Concurrent.STM.TQueue (TQueue, writeTQueue)

Having accessed the underlying queue you can write items, wrapped in Just, to it directly:

liftIO $ do
atomically $ do
writeTQueue queue (Just item)

A Nothing written to the underlying queue will signal the worker threads that the end of input has been reached and they can safely return.

Add an item to the queue.

Add a list of items to the queue.