mirror of
https://github.com/idris-lang/Idris2.git
synced 2024-12-20 10:02:03 +03:00
60 lines
1.5 KiB
Idris
60 lines
1.5 KiB
Idris
module Futures
|
|
|
|
import Data.List
|
|
import Data.So
|
|
import System
|
|
import System.Future
|
|
import System.Info
|
|
|
|
constant : IO ()
|
|
constant = do
|
|
let a = await $ fork "String"
|
|
putStrLn a
|
|
|
|
-- Issue in MacOS brew chez related to clock ( https://github.com/Homebrew/homebrew-core/pull/10159 )
|
|
-- Windows seems to be really flaky with usleep
|
|
extraSleep : (us : Int) -> So (us >= 0) => IO ()
|
|
extraSleep us =
|
|
if (os == "darwin" || isWindows)
|
|
then sleep (us `div` 10000)
|
|
else usleep us
|
|
|
|
partial
|
|
futureHelloWorld : (Int, String) -> IO (Future Unit)
|
|
futureHelloWorld (us, n) with (choose (us >= 0))
|
|
futureHelloWorld (us, n) | Left p = forkIO $ do
|
|
extraSleep us
|
|
putStrLn $ "Hello " ++ n ++ "!"
|
|
|
|
partial
|
|
simpleIO : IO (List Unit)
|
|
simpleIO = do
|
|
futures <- sequence $ futureHelloWorld <$> [(30000, "World"), (10000, "Bar"), (0, "Foo"), (20000, "Idris")]
|
|
let awaited = await <$> futures
|
|
pure awaited
|
|
|
|
nonbind : IO (Future ())
|
|
nonbind = forkIO $ putStrLn "This shouldn't print"
|
|
|
|
erasureAndNonbindTest : IO ()
|
|
erasureAndNonbindTest = do
|
|
_ <- forkIO $ do
|
|
putStrLn "This line is printed"
|
|
notUsed <- forkIO $ do
|
|
extraSleep 10000
|
|
putStrLn "This line is also printed"
|
|
let _ = nonbind
|
|
let n = nonbind
|
|
extraSleep 20000 -- Even if not explicitly awaited, we should let threads finish before exiting
|
|
|
|
map : IO ()
|
|
map = do
|
|
future1 <- forkIO $ do
|
|
extraSleep 10000
|
|
putStrLn "#2"
|
|
let future3 = map (const "#3") future1
|
|
future2 <- forkIO $ do
|
|
putStrLn "#1"
|
|
pure $ await future2
|
|
putStrLn (await future3)
|