Control.Scheduler

Main type for scheduling work. See withScheduler or withScheduler_ for ways to construct and use this data type.

This is a wrapper around Scheduler, but it also keeps a separate state for each individual worker. See withSchedulerWS or withSchedulerWS_ for ways to construct and use this data type.

Computed results of scheduled jobs.

Schedule an action to be picked up and computed by a worker from a pool of jobs. Similar to scheduleWorkId, except the job doesn't get the worker id.

Same as scheduleWork, but only for a Scheduler that doesn't keep the results.

Schedule an action to be picked up and computed by a worker from a pool of jobs. Argument supplied to the job will be the id of the worker doing the job. This is useful for identification of a thread that will be doing the work, since there is one-to-one mapping from ThreadId to WorkerId for a particular scheduler.

Same as scheduleWorkId, but only for a Scheduler that doesn't keep the results.

Schedule a job that will get a worker state passed as an argument

Same as scheduleWorkState, but dont' keep the result of computation.

Schedule the same action to run n times concurrently. This differs from replicateConcurrently by allowing the caller to use the Scheduler freely, or to allow early termination via terminate across all (identical) threads. To be called within a withScheduler block.

Same as replicateWork, but it does not retain the results of scheduled jobs

Batch is an artifical checkpoint that can be controlled by the user throughout the lifetime of a scheduler.

Run a single batch of jobs. Supplied action will not return until all jobs placed on the queue are done or the whole batch is cancelled with one of these cancelBatch, cancelBatch_ or cancelBatchWith.

It waits for all scheduled jobs to finish and collects the computed results into a list. It is a blocking operation, but if there are no jobs in progress it will return immediately. It is safe to continue using the supplied scheduler after this function returns. However, if any of the jobs resulted in an exception it will be rethrown by this function, which, unless caught, will further put the scheduler in a terminated state.

It is important to note that any job that hasn't had its results collected from the scheduler prior to starting the batch it will end up on the batch result list.

Same as runBatch, except it ignores results of computation

Same as runBatch, except it produces Results instead of a list.

Cancel batch with supplied identifier, which will lead to scheduler to return FinishedEarly result. This is an idempotent operation and has no affect if currently running batch does not match supplied identifier. Returns False when cancelling did not succeed due to mismatched identifier or does not return at all since all jobs get cancelled immediately. For trivial schedulers however there is no way to perform concurrent cancelation and it will return True.

Same as cancelBatch, but only works with schedulers that don't care about results

Same as cancelBatch_, but the result of computation will be set to FinishedEarlyWith

Check if the supplied batch has already finished.

This function gives a way to get access to the main batch that started implicitely.

As soon as possible try to terminate any computation that is being performed by all workers managed by this scheduler and collect whatever results have been computed, with supplied element guaranteed to being the last one. In case when Results type is returned this function will cause the scheduler to produce FinishedEarly

Important - With Seq strategy this will not stop other scheduled tasks from being computed, although it will make sure their results are discarded.

Similar to terminate, but for a Scheduler that does not keep any results of computation.

Important - In case of Seq computation strategy this function has no affect.

Same as terminate, but returning a single element list containing the supplied argument. This can be very useful for parallel search algorithms. In case when Results is the return type this function will cause the scheduler to produce FinishedEarlyWith

Important - Same as with terminate, when Seq strategy is used, this will not prevent computation from continuing, but the scheduler will return only the result supplied to this function.

A unique id for the worker in the Scheduler context. It will always be a number from 0 up to, but not including, the number of workers a scheduler has, which in turn can always be determined with numWorkers function.

Each worker is capable of keeping it's own state, that can be share for different schedulers, but not at the same time. In other words using the same WorkerStates on Control.Scheduler.withSchedulerS concurrently will result in an error. Can be initialized with initWorkerStates

Get the number of workers. Will mainly depend on the computation strategy and/or number of capabilities you have. Related function is getCompWorkers.

Get the computation strategy the states where initialized with.

Initialize a separate state for each worker.

Computation strategy to use when scheduling work.

Parallel computation using all available cores. Same as ParOn []

Parallel computation using all available cores. Same as ParN 0

Figure out how many workers will this computation strategy create.

Note - If at any point during program execution global number of capabilities gets changed with setNumCapabilities, it will have no affect on this function, unless it hasn't yet been called with Par or Par' arguments.

Replicate an action n times and schedule them acccording to the supplied computation strategy.

Just like replicateConcurrently, but discards the results of computation.

Map an action over each element of the Traversable t acccording to the supplied computation strategy.

Just like traverseConcurrently, but restricted to Foldable and discards the results of computation.

This is generally a faster way to traverse while ignoring the result rather than using mapM_.

Exception that gets thrown whenever concurrent access is attempted to the WorkerStates