11.1 Threads
Concurrency and Synchronization in The Racket Guide introduces threads.
See Threads for basic information on the Racket thread model. See also Futures and Places.
When a thread is created, it is placed into the management of the current custodian and added to the current thread group. A thread can have any number of custodian managers added through thread-resume. The allocation made by a thread is accounted to the thread’s custodian managers. See custodian-limit-memory for examples.
A thread that has not terminated can be garbage collected (see Garbage Collection) if it is unreachable and suspended or if it is unreachable and blocked on only unreachable events through functions such as semaphore-wait, semaphore-wait/enable-break, channel-put, channel-get, sync, sync/enable-break, or thread-wait. Beware, however, of a limitation on place-channel blocking; see the caveat in Places.
In GRacket, a handler thread for an eventspace is blocked on an internal semaphore when its event queue is empty. Thus, the handler thread is collectible when the eventspace is unreachable and contains no visible windows or running timers.
A thread can be used as a synchronizable event (see Events). A thread is ready for synchronization when thread-wait would not block; the synchronization result of a thread is the thread itself.
11.1.1 Creating Threads
procedure
procedure
(thread/suspend-to-kill thunk) → thread?
thunk : (-> any)
procedure
(call-in-nested-thread thunk [cust]) → any
thunk : (-> any) cust : custodian? = (current-custodian)
The nested thread’s exception handler is initialized to a procedure that jumps to the beginning of the thread and transfers the exception to the original thread. The handler thus terminates the nested thread and re-raises the exception in the original thread.
If the thread created by call-in-nested-thread dies before thunk returns, the exn:fail exception is raised in the original thread. If the original thread is killed before thunk returns, a break is queued for the nested thread.
If a break is queued for the original thread (with break-thread) while the nested thread is running, the break is redirected to the nested thread. If a break is already queued on the original thread when the nested thread is created, the break is moved to the nested thread. If a break remains queued on the nested thread when it completes, the break is moved to the original thread.
If the thread created by call-in-nested-thread dies while itself in a call to call-in-nested-thread, the outer call to call-in-nested-thread waits for the innermost nested thread to complete, and any breaks pending on the inner threads are moved to the original thread.
11.1.2 Suspending, Resuming, and Killing Threads
procedure
(thread-suspend thd) → void?
thd : thread?
procedure
(thread-resume thd [benefactor]) → void?
thd : thread? benefactor : (or/c thread? custodian? #f) = #f
If benefactor is a thread, whenever it is resumed from a suspended state in the future, then thd is also resumed. (Resuming thd may trigger the resumption of other threads that were previously attached to thd through thread-resume.)
New custodians may be added to thd’s set of managers. If benefactor is a thread, then all of the thread’s custodians are added to thd. Otherwise, benefactor is a custodian, and it is added to thd (unless the custodian is already shut down). If thd becomes managed by both a custodian and one or more of its subordinates, the redundant subordinates are removed from thd. If thd is suspended and a custodian is added, then thd is resumed only after the addition.
If benefactor is a thread, whenever it receives a new managing custodian in the future, then thd also receives the custodian. (Adding custodians to thd may trigger adding the custodians to other threads that were previously attached to thd through thread-resume.)
procedure
(kill-thread thd) → void?
thd : thread?
Unless otherwise noted, procedures provided by Racket (and GRacket) are kill-safe and suspend-safe; that is, killing or suspending a thread never interferes with the application of procedures in other threads. For example, if a thread is killed while extracting a character from an input port, the character is either completely consumed or not consumed, and other threads can safely use the port.
procedure
(break-thread thd [kind]) → void?
thd : thread? kind : (or/c #f 'hang-up 'terminate) = #f
procedure
(thread-running? thd) → any
thd : thread?
procedure
(thread-dead? thd) → any
thd : thread?
11.1.3 Synchronizing Thread State
procedure
(thread-wait thd) → void?
thd : thread?
Unless thd was created with thread/suspend-to-kill, a (thread-wait thd) may potentially continue even if thd is otherwise inaccessible, because a custodian shut down could terminate the thread. As a result, a thread blocking with thread-wait normally cannot be garbage collected (see Garbage Collection). As a special case, however, (thread-wait thd) blocks without preventing garbage collection of the thread if thd is the current thread, since the thread could only continue if a break escapes from the wait.
procedure
(thread-dead-evt thd) → evt?
thd : thread?
A thread waiting on the result of (thread-dead-evt thd) normally cannot itself be garbage collected, unless thd was created with thread/suspend-to-kill, along the same lines as waiting via thread-wait. However, there is no special case for waiting on the result of (thread-dead-evt thd) where thd is the current thread.
For a given thd, thread-dead-evt always returns the same (i.e., eq?) result.
procedure
(thread-resume-evt thd) → evt?
thd : thread?
procedure
(thread-suspend-evt thd) → evt?
thd : thread?
If thd was created with thread/suspend-to-kill, then waiting on (thread-suspend-evt thd) prevents garbage collection of the waiting thread in the same way as (thread-dead-evt another-thd) for a another-thd created via thread. Furthermore, since the event result is thd, waiting on (thread-suspend-evt thd) prevents garbage collection of thd.
11.1.4 Thread Mailboxes
Each thread has a mailbox through which it can receive arbitrary messages. In other words, each thread has a built-in asynchronous channel.
See also Buffered Asynchronous Channels.
procedure
(thread-send thd v [fail-thunk]) → any
thd : thread? v : any/c
fail-thunk : (or/c (-> any) #f) = (lambda () (raise-mismatch-error ....))
procedure
(thread-receive) → any/c
procedure
procedure
procedure
(thread-rewind-receive lst) → void?
lst : list?