File: AtomicModifyIORef.hs

package info (click to toggle)
ghc 9.10.3-1
  • links: PTS, VCS
  • area: main
  • in suites: sid
  • size: 168,924 kB
  • sloc: haskell: 713,548; ansic: 84,223; cpp: 30,255; javascript: 9,003; sh: 7,870; fortran: 3,527; python: 3,228; asm: 2,523; makefile: 2,326; yacc: 1,570; lisp: 532; xml: 196; perl: 111; csh: 2
file content (21 lines) | stat: -rw-r--r-- 457 bytes parent folder | download 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
import Control.Concurrent
import Control.Monad
import Data.IORef

main :: IO ()
main = do
    let nThreads = 10
        nIncrs = 10000

    ref <- newIORef (42 :: Int)
    dones <- replicateM nThreads $ do
        done <- newEmptyMVar
        forkIO $ do
           replicateM_ nIncrs $ atomicModifyIORef' ref $ \old -> (old + 1, ())
           putMVar done ()
        putStrLn "."
        return done

    mapM_ takeMVar dones
    readIORef ref >>= print