std/os/task▲toc

Experimental: Parallel tasks.

Note: very experimental and may not work as intended :-) See test/bench/koka/binarytrees.kk for example usage.

type lvarstd/os/task/lvar: V -> V<a>
fun get( lvar : lvarstd/os/task/lvar: V -> V<a>, bot : a, is-gte : (a, a) -> boolstd/core/types/bool: V ) : ndetstd/core/types/ndet: X a
fun lvar( init : a ) : lvarstd/os/task/lvar: V -> V<a>
fun put( lvar : lvarstd/os/task/lvar: V -> V<a>, x : a, monotonic-combine : (a, a) -> a ) : ()
type promisestd/os/task/promise: V -> V<a>

A promisestd/os/task/promise: V -> V<a> can be awaited for a result.

fun await( p : promisestd/os/task/promise: V -> V<a> ) : a

Await the result of a promise.

fun task( work : () -> a ) : promisestd/os/task/promise: V -> V<a>

Spark a pure computation in a separate thread of control.

fun list/await( ps : liststd/core/types/list: V -> V<promisestd/os/task/promise: V -> V<a>> ) : liststd/core/types/list: V -> V<a>

Await the result of a list of promises.

fun parallel( xs : liststd/core/types/list: V -> V<() -> a> ) : liststd/core/types/list: V -> V<a>

Run a list of pure computations in parallel.

fun task-set-default-concurrency( thread-count : intstd/core/types/int: V ) : iocstd/core/ioc: E ()
private import std/core/typesstd/core/types, std/core/hndstd/core/hnd, std/core/exnstd/core/exn, std/core/boolstd/core/bool, std/core/orderstd/core/order, std/core/charstd/core/char, std/core/intstd/core/int, std/core/vectorstd/core/vector, std/core/bytesstd/core/bytes, std/core/bslicestd/core/bslice, std/core/stringstd/core/string, std/core/sslicestd/core/sslice, std/core/liststd/core/list, std/core/maybestd/core/maybe, std/core/maybe2std/core/maybe2, std/core/eitherstd/core/either, std/core/resultstd/core/result, std/core/tuplestd/core/tuple, std/core/lazystd/core/lazy, std/core/showstd/core/show, std/core/debugstd/core/debug, std/core/delayedstd/core/delayed, std/core/consolestd/core/console, std/corestd/core, std/num/int32std/num/int32