priority-sync: Cooperative task prioritization.
In a simple use case, we want to run some expensive tasks in prioritized order, so that only one task is running on each
CPU (or hardware thread) at any time. For this simple case, four operations are needed:
let expensiveTask = threadDelay 1000000 pool <- simpleTaskPool forkIO $ claim Acquire (schedule pool 1) $ putStrLn "Task 1 started . . ." >> expensiveTask >> putStrLn "Task 1 completed." forkIO $ claim Acquire (schedule pool 3) $ putStrLn "Task 3 started . . ." >> expensiveTask >> putStrLn "Task 3 completed." forkIO $ claim Acquire (schedule pool 2) $ putStrLn "Task 2 started . . ." >> expensiveTask >> putStrLn "Task 2 completed." threadDelay 100000 -- contrive to wait for all tasks to become enqueued putStrLn "Starting pool: " startQueue pool threadDelay 4000000 -- contrive to wait for all tasks to become dequeued
Queues in an efficient easy-to-use-interface.
Rooms provide fully reentrant synchronization to any number of threads based on arbitrary resource constraints.
For example, the
Room from a
simpleTaskPool is constrained by
Queues provide task prioritization. A
Queue systematically examines (to a configurable depth) all waiting threads with their
priorities and resource constraints and wakes the most eagerly prioritized thread whose constraints can be satisfied.
TaskPools are not thread pools. The concept is similar to IO Completion Ports. There are no worker threads. If a number of threads are waiting,
the thread that is most likely to be processed next is woken and temporarily serves as a working thread.
TaskPools are backed by carefully written STM (software transactional memory) transactions.
A salient feature is that, because any thread can participate, a
TaskPool supports both bound threads and threads created with
The git repository is available at http://www.downstairspeople.org/git/priority-sync.git.
- priority-sync-0.1.0.1.tar.gz [browse] (Cabal source package)
- Package description (as included in the package)
For package maintainers and hackage trustees
- No Candidates
|Versions [RSS]||0.1.0.0, 0.1.0.1, 0.2.1.0, 0.2.1.1|
|Dependencies||base (>3), containers (>=0.1.0.1), heap, parallel (>=184.108.40.206), random, stm (>=220.127.116.11) [details]|
|Author||Christopher Lane Hinson|
|Maintainer||Christopher Lane Hinson <firstname.lastname@example.org>|
|Uploaded||by ChristopherLaneHinson at 2009-04-29T18:21:02Z|
|Reverse Dependencies||2 direct, 0 indirect [details]|
|Downloads||3104 total (11 in the last 30 days)|
|Rating||(no votes yet) [estimated by Bayesian average]|
|Status||Docs uploaded by user
Build status unknown [no reports yet]