Control.Monad.Schedule.OSThreadPool

Documentation

newtype OSThreadPool (n :: Nat) a

Constructors

OSThreadPool

Fields

• unOSThreadPool :: IO a

Instances

MonadIO (OSThreadPool n)

Defined in Control.Monad.Schedule.OSThreadPool

Methods

liftIO :: IO a -> OSThreadPool n a

Applicative (OSThreadPool n)

Defined in Control.Monad.Schedule.OSThreadPool

Methods

pure :: a -> OSThreadPool n a

(<*>) :: OSThreadPool n (a -> b) -> OSThreadPool n a -> OSThreadPool n b

liftA2 :: (a -> b -> c) -> OSThreadPool n a -> OSThreadPool n b -> OSThreadPool n c

(*>) :: OSThreadPool n a -> OSThreadPool n b -> OSThreadPool n b

(<*) :: OSThreadPool n a -> OSThreadPool n b -> OSThreadPool n a

Functor (OSThreadPool n)

Defined in Control.Monad.Schedule.OSThreadPool

Methods

fmap :: (a -> b) -> OSThreadPool n a -> OSThreadPool n b

(<$) :: a -> OSThreadPool n b -> OSThreadPool n a

Monad (OSThreadPool n)

Defined in Control.Monad.Schedule.OSThreadPool

Methods

(>>=) :: OSThreadPool n a -> (a -> OSThreadPool n b) -> OSThreadPool n b

(>>) :: OSThreadPool n a -> OSThreadPool n b -> OSThreadPool n b

return :: a -> OSThreadPool n a

(KnownNat n, (1 <=? n) ~ 'True) => MonadSchedule (OSThreadPool n)

Defined in Control.Monad.Schedule.OSThreadPool

Methods

schedule :: NonEmpty (OSThreadPool n a) -> OSThreadPool n (NonEmpty a, [OSThreadPool n a])

data WorkerLink a

Constructors

WorkerLink

Fields

• jobTChan :: TChan (Maybe (IO a))
• resultTChan :: TChan a

putJob :: WorkerLink a -> OSThreadPool n a -> IO ()

makeWorkerLink :: IO (WorkerLink a)

proxyForActions :: NonEmpty (OSThreadPool n a) -> Proxy n