diff --git a/moonpool/Moonpool/Background_thread/For_runner_implementors/index.html b/moonpool/Moonpool/Background_thread/For_runner_implementors/index.html index bc2b16c1..628ac157 100644 --- a/moonpool/Moonpool/Background_thread/For_runner_implementors/index.html +++ b/moonpool/Moonpool/Background_thread/For_runner_implementors/index.html @@ -5,4 +5,4 @@ shutdown:(wait:bool -> unit -> unit) -> run_async:(ls:Task_local_storage.t -> task -> unit) -> unit -> - t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t option ref Moonpool_private.Thread_local_storage_.key

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

+ t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t Moonpool_private.Thread_local_storage_.t

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

diff --git a/moonpool/Moonpool/Fifo_pool/For_runner_implementors/index.html b/moonpool/Moonpool/Fifo_pool/For_runner_implementors/index.html index d16ead2d..c50b0dc7 100644 --- a/moonpool/Moonpool/Fifo_pool/For_runner_implementors/index.html +++ b/moonpool/Moonpool/Fifo_pool/For_runner_implementors/index.html @@ -5,4 +5,4 @@ shutdown:(wait:bool -> unit -> unit) -> run_async:(ls:Task_local_storage.t -> task -> unit) -> unit -> - t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t option ref Moonpool_private.Thread_local_storage_.key

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

+ t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t Moonpool_private.Thread_local_storage_.t

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

diff --git a/moonpool/Moonpool/Runner/For_runner_implementors/index.html b/moonpool/Moonpool/Runner/For_runner_implementors/index.html index 3995f615..7ebc405c 100644 --- a/moonpool/Moonpool/Runner/For_runner_implementors/index.html +++ b/moonpool/Moonpool/Runner/For_runner_implementors/index.html @@ -5,4 +5,4 @@ shutdown:(wait:bool -> unit -> unit) -> run_async:(ls:Task_local_storage.t -> task -> unit) -> unit -> - t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t option ref Moonpool_private.Thread_local_storage_.key

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

+ t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t Moonpool_private.Thread_local_storage_.t

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

diff --git a/moonpool/Moonpool/Ws_pool/For_runner_implementors/index.html b/moonpool/Moonpool/Ws_pool/For_runner_implementors/index.html index 1559e11f..eb9c1162 100644 --- a/moonpool/Moonpool/Ws_pool/For_runner_implementors/index.html +++ b/moonpool/Moonpool/Ws_pool/For_runner_implementors/index.html @@ -5,4 +5,4 @@ shutdown:(wait:bool -> unit -> unit) -> run_async:(ls:Task_local_storage.t -> task -> unit) -> unit -> - t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t option ref Moonpool_private.Thread_local_storage_.key

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

+ t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

val k_cur_runner : t Moonpool_private.Thread_local_storage_.t

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

diff --git a/moonpool/Moonpool_private/Thread_local_storage_/index.html b/moonpool/Moonpool_private/Thread_local_storage_/index.html index 0c02eb63..afdbf2e0 100644 --- a/moonpool/Moonpool_private/Thread_local_storage_/index.html +++ b/moonpool/Moonpool_private/Thread_local_storage_/index.html @@ -1,2 +1,2 @@ -Thread_local_storage_ (moonpool.Moonpool_private.Thread_local_storage_)

Module Moonpool_private.Thread_local_storage_

Thread local storage

type 'a key

A TLS key for values of type 'a. This allows the storage of a single value of type 'a per thread.

val new_key : (unit -> 'a) -> 'a key

Allocate a new, generative key. When the key is used for the first time on a thread, the function is called to produce it.

This should only ever be called at toplevel to produce constants, do not use it in a loop.

val get : 'a key -> 'a

Get the value for the current thread.

val set : 'a key -> 'a -> unit

Set the value for the current thread.

+Thread_local_storage_ (moonpool.Moonpool_private.Thread_local_storage_)

Module Moonpool_private.Thread_local_storage_

Thread local storage

type 'a t

A TLS slot for values of type 'a. This allows the storage of a single value of type 'a per thread.

val create : unit -> 'a t
val get : 'a t -> 'a
  • raises Failure

    if not present

val get_opt : 'a t -> 'a option
val set : 'a t -> 'a -> unit