Data.Poolboy

Configuration

data PoolboySettings

Initial settings

Constructors

PoolboySettings

Fields

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

data WorkersCountSettings

Initial number of threads

Constructors

CapabilitiesWCS

getNumCapabilities based number

FixedWCS Int

Instances

Show WorkersCountSettings

Defined in Data.Poolboy

Methods

showsPrec :: Int -> WorkersCountSettings -> ShowS

show :: WorkersCountSettings -> String

showList :: [WorkersCountSettings] -> ShowS

Eq WorkersCountSettings

Defined in Data.Poolboy

Methods

(==) :: WorkersCountSettings -> WorkersCountSettings -> Bool

(/=) :: WorkersCountSettings -> WorkersCountSettings -> Bool

defaultPoolboySettings :: PoolboySettings

Usual configuration CapabilitiesWCS and no log

poolboySettingsWith :: Int -> PoolboySettings

Arbitrary-numbered settings

simpleSerializedLogger :: IO (String -> IO ())

Simple (but not particularly performant) serialized logger

Running

data WorkQueue

withPoolboy :: PoolboySettings -> WaitingStopStrategy -> (WorkQueue -> IO a) -> IO a

backet-based usage (recommended)

newPoolboy :: PoolboySettings -> IO WorkQueue

Standalone/manual usage

Driving

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

Request a worker number adjustment

waitReadyQueue :: WorkQueue -> IO ()

Block until one worker is available

Stopping

stopWorkQueue :: WorkQueue -> IO ()

Request stopping wrokers

isStopedWorkQueue :: WorkQueue -> IO Bool

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

type WaitingStopStrategy = WorkQueue -> IO ()

waitingStopTimeout :: Int -> WaitingStopStrategy

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

waitingStopFinishWorkers :: WaitingStopStrategy

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

Enqueueing

enqueue :: WorkQueue -> IO () -> IO ()

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

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

Enqueue action and some actions to be run after it