Data.Poolboy · poolboy-0.2.2.0

Configuration

5 declarations

datadata PoolboySettings

#

Initial settings

Constructors

PoolboySettings
- workersCount :: WorkersCountSettings
- log :: String -> IO ()

datadata WorkersCountSettings

#

Initial number of threads

Constructors

CapabilitiesWCS
getNumCapabilities based number
FixedWCS Int

Instances2Eq, Show

Eq WorkersCountSettingsDefined in poolboy-0.2.2.0 · Data.Poolboy
Show WorkersCountSettingsDefined in poolboy-0.2.2.0 · Data.Poolboy

valuedefaultPoolboySettings :: PoolboySettings

#

Usual configuration CapabilitiesWCS and no log

valuepoolboySettingsWith :: Int -> PoolboySettings

#

Arbitrary-numbered settings

valuesimpleSerializedLogger :: IO (String -> IO ())

#

Simple (but not particularly performant) serialized logger

Running

3 declarations

datadata WorkQueue

#

valuewithPoolboy

:: PoolboySettings
-> WaitingStopStrategy
-> WorkQueue -> IO a
-> IO a

#

backet-based usage (recommended)

valuenewPoolboy :: PoolboySettings -> IO WorkQueue

#

Standalone/manual usage

Driving

2 declarations

valuechangeDesiredWorkersCount :: WorkQueue -> Int -> IO ()

#

Request a worker number adjustment

valuewaitReadyQueue :: WorkQueue -> IO ()

#

Block until one worker is available

Stopping

5 declarations

valuestopWorkQueue :: WorkQueue -> IO ()

#

Request stopping wrokers

valueisStopedWorkQueue :: WorkQueue -> IO Bool

#

Non-blocking check of the work queue's running status

typetype WaitingStopStrategy = WorkQueue -> IO ()

#

valuewaitingStopTimeout :: Int -> WaitingStopStrategy

#

Block until the queue is totally stopped or deadline (in micro seconds) is reached

valuewaitingStopFinishWorkers :: WaitingStopStrategy

#

Block until the queue is totally stopped (no more running worker)

Enqueueing

2 declarations

valueenqueue :: WorkQueue -> IO () -> IO ()

#

Enqueue one action in the work queue (non-blocking)

valueenqueueAfter :: Foldable f => WorkQueue -> IO () -> f (IO ()) -> IO ()

#

Enqueue action and some actions to be run after it