ThreadError
pub enum ThreadError = { OutOfMemory, CreateFailed, JoinFailed, DetachFailed, AlreadyJoined }Variants
OutOfMemoryCreateFailedJoinFailedDetachFailedAlreadyJoined
thread/core
alloc_in
privatefn alloc_in[A: allocators.GeneralAllocator](ac: A, size: usize) option[ref void]free_in
privatefn free_in[A: allocators.GeneralAllocator](ac: A, ptr: ref void) voidThread
pub type Thread = { handle: ref void, joined: bool }Opaque thread handle — wraps pthread_t on POSIX, HANDLE on Windows.
Fields
| Name | Type |
|---|---|
handle | ref void |
joined | bool |
pthread_create
when posixprivateextern (C) fn pthread_create(thread: ref void, attr: ref void, start_routine: usize, arg: ref void) i32 = trust { ... } = "pthread_create"pthread_join
when posixprivateextern (C) fn pthread_join(thread: ref void, retval: ref void) i32 = trust { ... } = "pthread_join"pthread_detach
when posixprivateextern (C) fn pthread_detach(thread: ref void) i32 = trust { ... } = "pthread_detach"pthread_self
when posixprivateextern (C) fn pthread_self() ref void = trust { ... } = "pthread_self"sched_yield
when posixprivateextern (C) fn sched_yield() i32 = trust { ... } = "sched_yield"CreateThread
when windowsprivateextern (C) fn CreateThread(lpThreadAttributes: ref void, dwStackSize: usize, lpStartAddress: usize, lpParameter: ref void, dwCreationFlags: u32, lpThreadId: ref u32) ref void = trust { ... } = "CreateThread"WaitForSingleObject
when windowsprivateextern (C) fn WaitForSingleObject(hHandle: ref void, dwMilliseconds: u32) u32 = trust { ... } = "WaitForSingleObject"CloseHandle
when windowsprivateextern (C) fn CloseHandle(hObject: ref void) i32 = trust { ... } = "CloseHandle"GetCurrentThreadId
when windowsprivateextern (C) fn GetCurrentThreadId() u32 = trust { ... } = "GetCurrentThreadId"SwitchToThread
when windowsprivateextern (C) fn SwitchToThread() i32 = trust { ... } = "SwitchToThread"new
pub fn (Thread) new[A: allocators.GeneralAllocator](ac: A, entry: fn(ref void) ref void, arg: ref void) result[ref void, ThreadError]Create a new thread running `entry` with the given `arg`.
join
pub fn (Thread) join[A: allocators.GeneralAllocator](ac: A, thread: Thread) result[ref void, ThreadError]detach
pub fn (Thread) detach[A: allocators.GeneralAllocator](ac: A, thread: Thread) result[void, ThreadError]free
pub fn (Thread) free[A: allocators.GeneralAllocator](ac: A, thread: mut Thread) voidcurrent_thread_id
pub fn current_thread_id() usizeyield_thread
pub fn yield_thread() void = trust { ... }Mutex
pub type Mutex = { ptr: ref void }Fields
| Name | Type |
|---|---|
ptr | ref void |
pthread_mutex_init
when posixprivateextern (C) fn pthread_mutex_init(mutex: ref void, attr: ref void) i32 = trust { ... } = "pthread_mutex_init"pthread_mutex_destroy
when posixprivateextern (C) fn pthread_mutex_destroy(mutex: ref void) i32 = trust { ... } = "pthread_mutex_destroy"pthread_mutex_lock
when posixprivateextern (C) fn pthread_mutex_lock(mutex: ref void) i32 = trust { ... } = "pthread_mutex_lock"pthread_mutex_unlock
when posixprivateextern (C) fn pthread_mutex_unlock(mutex: ref void) i32 = trust { ... } = "pthread_mutex_unlock"InitializeCriticalSection
when windowsprivateextern (C) fn InitializeCriticalSection(lpCriticalSection: ref void) void = trust { ... } = "InitializeCriticalSection"DeleteCriticalSection
when windowsprivateextern (C) fn DeleteCriticalSection(lpCriticalSection: ref void) void = trust { ... } = "DeleteCriticalSection"EnterCriticalSection
when windowsprivateextern (C) fn EnterCriticalSection(lpCriticalSection: ref void) void = trust { ... } = "EnterCriticalSection"LeaveCriticalSection
when windowsprivateextern (C) fn LeaveCriticalSection(lpCriticalSection: ref void) void = trust { ... } = "LeaveCriticalSection"new
pub fn (Mutex) new[A: allocators.GeneralAllocator](ac: A) option[ref void]lock
pub fn (Mutex) lock(m: Mutex) voidunlock
pub fn (Mutex) unlock(m: Mutex) void = trust { ... }free
pub fn (Mutex) free[A: allocators.GeneralAllocator](ac: A, m: mut Mutex) voidthread_test_entry
privatefn thread_test_entry(arg: ref void) ref void