Control.Concurrent.Futures.Buffer

This module implements one-place buffers using futures. Warning: All operations on buffers should only be used within the global wrapper function withFuturesDo!

Documentation

type Buffer a = (Cell Bool, Cell Bool, Cell a, Cell (Bool -> IO ()))

The buffer type contains of 3 cells and a handle. The first 2 cells are for communication of either a put or get is allowed. The thrist cell is the storage cell, the last cell contains a the active handle.

newBuf :: IO (Buffer a)

Creates a new empty buffer.

putBuf :: Buffer a -> a -> IO ()

Puts a new value to a buffer. putBuf blocks if the buffer is full.

getBuf :: Buffer a -> IO a

Gets the contents of a non-empty buffer. If the buffer is empty, then this function blocks until the buffer is filled.