Thread creation and termination
val create : ('a -> 'b) -> 'a -> t
Thread.create funct arg
creates a new thread of control, in which the function applicationfunct arg
is executed concurrently with the other threads of the program. The application ofThread.create
returns the handle of the newly created thread. The new thread terminates when the applicationfunct arg
returns, either normally or by raising an uncaught exception. In the latter case, the exception is printed on standard error, but not propagated back to the parent thread. Similarly, the result of the applicationfunct arg
is discarded and not directly accessible to the parent thread.
val self : unit -> t
Return the thread currently executing.
val id : t -> int
Return the identifier of the given thread. A thread identifier is an integer that identifies uniquely the thread. It can be used to build data structures indexed by threads.
val kill : t -> unit
Terminate prematurely the thread whose handle is given.
Suspending threads
val delay : float -> unit
delay d
suspends the execution of the calling thread ford
seconds. The other program threads continue to run during this time.
val join : t -> unit
join th
suspends the execution of the calling thread until the threadth
has terminated.
val wait_read : Unix.file_descr -> unit
See
Thread.wait_write
.
val wait_write : Unix.file_descr -> unit
This function does nothing in this implementation.
val wait_timed_read : Unix.file_descr -> float -> bool
val wait_timed_write : Unix.file_descr -> float -> bool
Suspend the execution of the calling thread until at least one character or EOF is available for reading (
wait_read
) or one character can be written without blocking (wait_write
) on the given Unix file descriptor. Wait for at most the amount of time given as second argument (in seconds). Returntrue
if the file descriptor is ready for input/output andfalse
if the timeout expired.These functions return immediately
true
in the Win32 implementation.
val select : Unix.file_descr list -> Unix.file_descr list -> Unix.file_descr list -> float -> Unix.file_descr list * Unix.file_descr list * Unix.file_descr list
Suspend the execution of the calling thread until input/output becomes possible on the given Unix file descriptors. The arguments and results have the same meaning as for
Unix.select
. This function is not implemented yet under Win32.
val wait_pid : int -> int * Unix.process_status
wait_pid p
suspends the execution of the calling thread until the process specified by the process identifierp
terminates. Returns the pid of the child caught and its termination status, as perUnix.wait
. This function is not implemented under MacOS.
val yield : unit -> unit
Re-schedule the calling thread without suspending it. This function can be used to give scheduling hints, telling the scheduler that now is a good time to switch to other threads.
Management of signals
val sigmask : Unix.sigprocmask_command -> int list -> int list
sigmask cmd sigs
changes the set of blocked signals for the calling thread. Ifcmd
isSIG_SETMASK
, blocked signals are set to those in the listsigs
. Ifcmd
isSIG_BLOCK
, the signals insigs
are added to the set of blocked signals. Ifcmd
isSIG_UNBLOCK
, the signals insigs
are removed from the set of blocked signals.sigmask
returns the set of previously blocked signals for the thread.
val wait_signal : int list -> int
wait_signal sigs
suspends the execution of the calling thread until the process receives one of the signals specified in the listsigs
. It then returns the number of the signal received. Signal handlers attached to the signals insigs
will not be invoked. The signalssigs
are expected to be blocked before callingwait_signal
.