| Safe Haskell | None |
|---|---|
| Language | Haskell98 |
Data.Concurrent.Deque.Tests
Description
This module contains a battery of simple tests for queues implementing the interface defined in ` Data.Concurrent.Deque.Class`.
Synopsis
- test_fifo_filldrain :: DequeClass d => d Elt -> IO ()
- test_fifo_OneBottleneck :: DequeClass d => Bool -> Int -> d Elt -> IO ()
- tests_fifo :: DequeClass d => (forall elt. IO (d elt)) -> Test
- test_ws_triv1 :: PopL d => d [Char] -> IO ()
- test_ws_triv2 :: PopL d => d [Char] -> IO ()
- tests_wsqueue :: PopL d => (forall elt. IO (d elt)) -> Test
- test_parfib_work_stealing :: (DequeClass d, PopL d) => Elt -> IO (d Elt) -> IO ()
- tests_all :: PopL d => (forall elt. IO (d elt)) -> Test
- numElems :: Int
- getNumAgents :: IO Int
- producerRatio :: Double
- setTestThreads :: Int -> Test -> Test
- appendLabels :: String -> [Test] -> Test
- appendLabel :: String -> Test -> Test
- stdTestHarness :: IO Test -> IO ()
- type Elt = Int64
- forkJoin :: Int -> (Int -> IO b) -> IO [b]
- timeit :: IO a -> IO a
- fibSize :: Int64
Tests for simple FIFOs.
test_fifo_filldrain :: DequeClass d => d Elt -> IO () Source #
This test serially fills up a queue and then drains it.
test_fifo_OneBottleneck :: DequeClass d => Bool -> Int -> d Elt -> IO () Source #
This test splits the numAgents threads into producers and
consumers which all communicate through a SINGLE queue. Each
thread performs its designated operation as fast as possible. The
Int argument total designates how many total items should be
communicated (irrespective of numAgents).
tests_fifo :: DequeClass d => (forall elt. IO (d elt)) -> Test Source #
This creates an HUnit test list to perform all the tests that apply to a single-ended (threadsafe) queue. It requires thread safety at both ends.
Tests for Work-stealing queues.
tests_wsqueue :: PopL d => (forall elt. IO (d elt)) -> Test Source #
Aggregate tests for work stealing queues. None of these require thread-safety on the left end. There is some duplication with tests_fifo.
test_parfib_work_stealing :: (DequeClass d, PopL d) => Elt -> IO (d Elt) -> IO () Source #
All deque tests, aggregated.
tests_all :: PopL d => (forall elt. IO (d elt)) -> Test Source #
This requires double ended queues that are threadsafe on BOTH ends.
Testing parameters
getNumAgents :: IO Int Source #
How many communicating agents are there? By default one per thread used by the RTS.
producerRatio :: Double Source #
It is possible to have imbalanced concurrency where there is more contention on the producing or consuming side (which corresponds to settings of this parameter less than or greater than 1).
Utility for tweaking test suites
setTestThreads :: Int -> Test -> Test Source #
Dig through the test constructors to find the leaf IO actions and bracket them with a thread-setting action.
appendLabels :: String -> [Test] -> Test Source #
This version has the option of being smarter about how it handles uniformly labeling many tests.
appendLabel :: String -> Test -> Test Source #
Dig through the test constructors and add a new string to the first label found. If no such label exists, add one.