source: doc/theses/colby_parsons_MMAth/text/waituntil.tex @ d4c1d1f

Last change on this file since d4c1d1f was d4c1d1f, checked in by Peter A. Buhr <pabuhr@…>, 11 months ago

more proofreading of chapter waituntil

  • Property mode set to 100644
File size: 52.0 KB
Line 
1% ======================================================================
2% ======================================================================
3\chapter{Waituntil}\label{s:waituntil}
4% ======================================================================
5% ======================================================================
6
7Consider the following motivating problem.
8There are $N$ stalls (resources) in a bathroom and there are $M$ people (threads) using the bathroom.
9Each stall has its own lock since only one person may occupy a stall at a time.
10Humans solve this problem in the following way.
11They check if all of the stalls are occupied.
12If not, they enter and claim an available stall.
13If they are all occupied, people queue and watch the stalls until one is free, and then enter and lock the stall.
14This solution can be implemented on a computer easily, if all threads are waiting on all stalls and agree to queue.
15
16Now the problem is extended.
17Some stalls are wheelchair accessible and some stalls have gender identification.
18Each person (thread) may be limited to only one kind of stall or may choose among different kinds of stalls that match their criteria.
19Immediately, the problem becomes more difficult.
20A single queue no longer solves the problem.
21What happens when there is a stall available that the person at the front of the queue cannot choose?
22The na\"ive solution has each thread spin indefinitely continually checking every matching kind of stall(s) until a suitable one is free.
23This approach is insufficient since it wastes cycles and results in unfairness among waiting threads as a thread can acquire the first matching stall without regard to the waiting time of other threads.
24Waiting for the first appropriate stall (resource) that becomes available without spinning is an example of \gls{synch_multiplex}: the ability to wait synchronously for one or more resources based on some selection criteria.
25
26\section{History of Synchronous Multiplexing}
27There is a history of tools that provide \gls{synch_multiplex}.
28Some well known \gls{synch_multiplex} tools include Unix system utilities: @select@~\cite{linux:select}, @poll@~\cite{linux:poll}, and @epoll@~\cite{linux:epoll}, and the @select@ statement provided by Go~\cite{go:selectref}, Ada~\cite[\S~9.7]{Ada16}, and \uC~\cite[\S~3.3.1]{uC++}.
29The concept and theory surrounding \gls{synch_multiplex} was introduced by Hoare in his 1985 book, Communicating Sequential Processes (CSP)~\cite{Hoare85},
30\begin{quote}
31A communication is an event that is described by a pair $c.v$ where $c$ is the name of the channel on which the communication takes place and $v$ is the value of the message which passes.~\cite[p.~113]{Hoare85}
32\end{quote}
33The ideas in CSP were implemented by Roscoe and Hoare in the language Occam~\cite{Roscoe88}.
34
35Both CSP and Occam include the ability to wait for a \Newterm{choice} among receiver channels and \Newterm{guards} to toggle which receives are valid.
36For example,
37\begin{cfa}[mathescape]
38(@G1@(x) $\rightarrow$ P @|@ @G2@(y) $\rightarrow$ Q )
39\end{cfa}
40waits for either channel @x@ or @y@ to have a value, if and only if guards @G1@ and @G2@ are true;
41if only one guard is true, only one channel receives, and if both guards are false, no receive occurs.
42% extended CSP with a \gls{synch_multiplex} construct @ALT@, which waits for one resource to be available and then executes a corresponding block of code.
43In detail, waiting for one resource out of a set of resources can be thought of as a logical exclusive-or over the set of resources.
44Guards are a conditional operator similar to an @if@, except they apply to the resource being waited on.
45If a guard is false, then the resource it guards is not in the set of resources being waited on.
46If all guards are false, the ALT, Occam's \gls{synch_multiplex} statement, does nothing and the thread continues.
47Guards can be simulated using @if@ statements as shown in~\cite[rule~2.4, p~183]{Roscoe88}
48\begin{lstlisting}[basicstyle=\rm,mathescape]
49ALT( $b$ & $g$ $P$, $G$ ) = IF ( $b$ ALT($\,g$ $P$, $G$ ), $\neg\,$b ALT( $G$ ) )                        (boolean guard elim).
50\end{lstlisting}
51but require $2^N-1$ @if@ statements, where $N$ is the number of guards.
52The exponential blowup comes from applying rule 2.4 repeatedly, since it works on one guard at a time.
53Figure~\ref{f:wu_if} shows in \CFA an example of applying rule 2.4 for three guards.
54Also, notice the additional code duplication for statements @S1@, @S2@, and @S3@.
55
56\begin{figure}
57\centering
58\begin{lrbox}{\myboxA}
59\begin{cfa}
60when( G1 )
61        waituntil( R1 ) S1
62or when( G2 )
63        waituntil( R2 ) S2
64or when( G3 )
65        waituntil( R3 ) S3
66
67
68
69
70
71
72
73\end{cfa}
74\end{lrbox}
75
76\begin{lrbox}{\myboxB}
77\begin{cfa}
78if ( G1 )
79        if ( G2 )
80                if ( G3 ) waituntil( R1 ) S1 or waituntil( R2 ) S2 or waituntil( R3 ) S3
81                else waituntil( R1 ) S1 or waituntil( R2 ) S2
82        else
83                if ( G3 ) waituntil( R1 ) S1 or waituntil( R3 ) S3
84                else waituntil( R1 ) S1
85else
86        if ( G2 )
87                if ( G3 ) waituntil( R2 ) S2 or waituntil( R3 ) S3
88                else waituntil( R2 ) S2
89        else
90                if ( G3 ) waituntil( R3 ) S3
91\end{cfa}
92\end{lrbox}
93
94\subfloat[Guards]{\label{l:guards}\usebox\myboxA}
95\hspace*{5pt}
96\vrule
97\hspace*{5pt}
98\subfloat[Simulated Guards]{\label{l:simulated_guards}\usebox\myboxB}
99\caption{\CFA guard simulated with \lstinline{if} statement.}
100\label{f:wu_if}
101\end{figure}
102
103When discussing \gls{synch_multiplex} implementations, the resource being multiplexed is important.
104While CSP waits on channels, the earliest known implementation of synch\-ronous multiplexing is Unix's @select@~\cite{linux:select}, multiplexing over file descriptors.
105The @select@ system-call is passed three sets of file descriptors (read, write, exceptional) to wait on and an optional timeout.
106@select@ blocks until either some subset of file descriptors are available or the timeout expires.
107All file descriptors that are ready are returned by modifying the argument sets to only contain the ready descriptors.
108
109This early implementation differs from the theory presented in CSP: when the call from @select@ returns it may provide more than one ready file descriptor.
110As such, @select@ has logical-or multiplexing semantics, whereas the theory described exclusive-or semantics.
111It is possible to achieve exclusive-or semantics with @select@ by arbitrarily operating on only one of the returned descriptors.
112@select@ passes the interest set of file descriptors between application and kernel in the form of a worst-case sized bit-mask, where the worst-case is the largest numbered file descriptor.
113@poll@ reduces the size of the interest sets changing from a bit mask to a linked data structure, independent of the file-descriptor values.
114@epoll@ further reduces the data passed per call by keeping the interest set in the kernel, rather than supplying it on every call.
115
116These early \gls{synch_multiplex} tools interact directly with the operating system and others are used to communicate among processes.
117Later, \gls{synch_multiplex} started to appear in applications, via programming languages, to support fast multiplexed concurrent communication among threads.
118An early example of \gls{synch_multiplex} is the @select@ statement in Ada~\cite[\S~9.7]{Ichbiah79}.
119This @select@ allows a task object, with their own threads, to multiplex over a subset of asynchronous calls to its methods.
120The Ada @select@ has the same exclusive-or semantics and guards as Occam ALT;
121however, it multiplexes over methods rather than channels.
122
123\begin{figure}
124\begin{lstlisting}[language=ada,literate=]
125task type buffer is -- thread
126        ... -- buffer declarations
127        count : integer := 0;
128begin -- thread starts here
129        loop
130                select
131                        when count < Size => -- guard
132                        accept insert( elem : in ElemType ) do  -- method
133                                ... -- add to buffer
134                                count := count + 1;
135                        end;
136                        -- executed if this accept called
137                or
138                        when count > 0 => -- guard
139                        accept remove( elem : out ElemType ) do  -- method
140                                ... --remove and return from buffer via parameter
141                                count := count - 1;
142                        end;
143                        -- executed if this accept called
144                or delay 10.0;  -- unblock after 10 seconds without call
145                or else -- do not block, cannot appear with delay
146                end select;
147        end loop;
148end buffer;
149var buf : buffer; -- create task object and start thread in task body
150\end{lstlisting}
151\caption{Ada Bounded Buffer}
152\label{f:BB_Ada}
153\end{figure}
154
155Figure~\ref{f:BB_Ada} shows the outline of a bounded buffer implemented with an Ada task.
156Note, a task method is associated with the \lstinline[language=ada]{accept} clause of the \lstinline[language=ada]{select} statement, rather than being a separate routine.
157The thread executing the loop in the task body blocks at the \lstinline[language=ada]{select} until a call occurs to @insert@ or @remove@.
158Then the appropriate \lstinline[language=ada]{accept} method is run with the called arguments.
159Hence, the \lstinline[language=ada]{select} statement provides rendezvous points for threads, rather than providing channels with message passing.
160The \lstinline[language=ada]{select} statement also provides a timeout and @else@ (nonblocking), which changes synchronous multiplexing to asynchronous.
161Now the thread polls rather than blocks.
162
163Another example of programming-language \gls{synch_multiplex} is Go using a @select@ statement with channels~\cite{go:selectref}.
164Figure~\ref{l:BB_Go} shows the outline of a bounded buffer implemented with a Go routine.
165Here two channels are used for inserting and removing by client producers and consumers, respectively.
166(The @term@ and @stop@ channels are used to synchronize with the program main.)
167Go's @select@ has the same exclusive-or semantics as the ALT primitive from Occam and associated code blocks for each clause like ALT and Ada.
168However, unlike Ada and ALT, Go does not provide guards for the \lstinline[language=go]{case} clauses of the \lstinline[language=go]{select}.
169Go also provides a timeout via a channel and a @default@ clause like Ada @else@ for asynchronous multiplexing.
170
171\begin{figure}
172\centering
173
174\begin{lrbox}{\myboxA}
175\begin{lstlisting}[language=go,literate=]
176func main() {
177        insert := make( chan int, Size )
178        remove := make( chan int, Size )
179        term := make( chan string )
180        finish := make( chan string )
181
182        buf := func() {
183                L: for {
184                        select { // wait for message
185                          case i = <- buffer:
186                          case <- term: break L
187                        }
188                        remove <- i;
189                }
190                finish <- "STOP" // completion
191        }
192        go buf() // start thread in buf
193}
194
195
196
197
198\end{lstlisting}
199\end{lrbox}
200
201\begin{lrbox}{\myboxB}
202\begin{lstlisting}[language=uC++=]
203_Task BoundedBuffer {
204        ... // buffer declarations
205        int count = 0;
206  public:
207        void insert( int elem ) {
208                ... // add to buffer
209                count += 1;
210        }
211        int remove() {
212                ... // remove and return from buffer
213                count -= 1;
214        }
215  private:
216        void main() {
217                for ( ;; ) {
218                        _Accept( ~buffer ) break;
219                        or _When ( count < Size ) _Accept( insert );
220                        or _When ( count > 0 ) _Accept( remove );
221                }
222        }
223};
224buffer buf; // start thread in main method
225\end{lstlisting}
226\end{lrbox}
227
228\subfloat[Go]{\label{l:BB_Go}\usebox\myboxA}
229\hspace*{5pt}
230\vrule
231\hspace*{5pt}
232\subfloat[\uC]{\label{l:BB_uC++}\usebox\myboxB}
233
234\caption{Bounded Buffer}
235\label{f:AdaMultiplexing}
236\end{figure}
237
238Finally, \uC provides \gls{synch_multiplex} with Ada-style @select@ over monitor and task methods with the @_Accept@ statement~\cite[\S~2.9.2.1]{uC++}, and over futures with the @_Select@ statement~\cite[\S~3.3.1]{uC++}.
239The @_Select@ statement extends the ALT/Go @select@ by offering both @and@ and @or@ semantics, which can be used together in the same statement.
240Both @_Accept@ and @_Select@ statements provide guards for multiplexing clauses, as well as, timeout, and @else@ clauses.
241
242There are other languages that provide \gls{synch_multiplex}, including Rust's @select!@ over futures~\cite{rust:select}, OCaml's @select@ over channels~\cite{ocaml:channel}, and C++14's @when_any@ over futures~\cite{cpp:whenany}.
243Note that while C++14 and Rust provide \gls{synch_multiplex}, the implementations leave much to be desired as both rely on polling to wait on multiple resources.
244
245\section{Other Approaches to Synchronous Multiplexing}
246
247To avoid the need for \gls{synch_multiplex}, all communication among threads/processes must come from a single source.
248For example, in Erlang each process has a single heterogeneous mailbox that is the sole source of concurrent communication, removing the need for \gls{synch_multiplex} as there is only one place to wait on resources.
249Similar, actor systems circumvent the \gls{synch_multiplex} problem as actors only block when waiting for the next message never in a behaviour.
250While these approaches solve the \gls{synch_multiplex} problem, they introduce other issues.
251Consider the case where a thread has a single source of communication and it wants a set of @N@ resources.
252It must sequentially request the @N@ resources and wait for each response.
253During the receives for the @N@ resources, it can receive other communication, and has to save and postpone these communications, or discard them.
254% If the requests for the other resources need to be retracted, the burden falls on the programmer to determine how to synchronize appropriately to ensure that only one resource is delivered.
255
256\section{\CFA's Waituntil Statement}
257
258The new \CFA \gls{synch_multiplex} utility introduced in this work is the @waituntil@ statement.
259There already exists a @waitfor@ statement in \CFA that supports Ada-style \gls{synch_multiplex} over monitor methods~\cite{Delisle21}, so this @waituntil@ focuses on synchronizing over other resources.
260All of the \gls{synch_multiplex} features mentioned so far are monomorphic, only waiting on one kind of resource: Unix @select@ supports file descriptors, Go's @select@ supports channel operations, \uC's @select@ supports futures, and Ada's @select@ supports monitor method calls.
261The \CFA @waituntil@ is polymorphic and provides \gls{synch_multiplex} over any objects that satisfy the trait in Figure~\ref{f:wu_trait}.
262No other language provides a synchronous multiplexing tool polymorphic over resources like \CFA's @waituntil@.
263
264\begin{figure}
265\begin{cfa}
266forall(T & | sized(T))
267trait is_selectable {
268        // For registering a waituntil stmt on a selectable type
269        bool register_select( T &, select_node & );
270
271        // For unregistering a waituntil stmt from a selectable type
272        bool unregister_select( T &, select_node & );
273
274        // on_selected is run on the selecting thread prior to executing
275        // the statement associated with the select_node
276        bool on_selected( T &, select_node & );
277};
278\end{cfa}
279\caption{Trait for types that can be passed into \CFA's \lstinline{waituntil} statement.}
280\label{f:wu_trait}
281\end{figure}
282
283Currently locks, channels, futures and timeouts are supported by the @waituntil@ statement, and this set can be expanded through the @is_selectable@ trait as other use-cases arise.
284The @waituntil@ statement supports guard clauses, both @or@ and @and@ semantics, and timeout and @else@ for asynchronous multiplexing.
285Figure~\ref{f:wu_example} shows a \CFA @waituntil@ usage, which is waiting for either @Lock@ to be available \emph{or} for a value to be read from @Channel@ into @i@ \emph{and} for @Future@ to be fulfilled \emph{or} a timeout of one second.
286Note, the expression inside a @waituntil@ clause is evaluated once at the start of the @waituntil@ algorithm.
287
288\begin{figure}
289\begin{cfa}
290future(int) Future;
291channel(int) Channel;
292owner_lock Lock;
293int i = 0;
294
295waituntil( Lock ) { ... }
296or when( i == 0 ) waituntil( i << Channel ) { ... }
297and waituntil( Future ) { ... }
298or waituntil( timeout( 1`s ) ) { ... }
299// else { ... }
300\end{cfa}
301\caption{Example of \CFA's waituntil statement}
302\label{f:wu_example}
303\end{figure}
304
305\section{Waituntil Semantics}
306
307The @waituntil@ semantics has two parts: the semantics of the statement itself, \ie @and@, @or@, @when@ guards, and @else@ semantics, and the semantics of how the @waituntil@ interacts with types like locks, channels, and futures.
308
309\subsection{Statement Semantics}
310
311The @or@ semantics are the most straightforward and nearly match those laid out in the ALT statement from Occam.
312The clauses have an exclusive-or relationship where the first available one is run and only one clause is run.
313\CFA's @or@ semantics differ from ALT semantics: instead of randomly picking a clause when multiple are available, the first clause in the @waituntil@ that is available is executed.
314For example, in the following example, if @foo@ and @bar@ are both available, @foo@ is always selected since it comes first in the order of @waituntil@ clauses.
315\begin{cfa}
316future(int) bar, foo;
317waituntil( foo ) { ... } or waituntil( bar ) { ... }
318\end{cfa}
319The reason for this semantics is that prioritizing resources can be useful in certain problems.
320In the rare case where there is a starvation problem with the ordering, it possible to follow a @waituntil@ with its reverse form:
321\begin{cfa}
322waituntil( foo ) { ... } or waituntil( bar ) { ... } // prioritize foo
323waituntil( bar ) { ... } or waituntil( foo ) { ... } // prioritize bar
324\end{cfa}
325
326The \CFA @and@ semantics match the @and@ semantics of \uC \lstinline[language=uC++]{_Select}.
327When multiple clauses are joined by @and@, the @waituntil@ makes a thread wait for all to be available, but still runs the corresponding code blocks \emph{as they become available}.
328When an @and@ clause becomes available, the waiting thread unblocks and runs that clause's code-block, and then the thread waits again for the next available clause or the @waituntil@ statement is now true.
329This semantics allows work to be done in parallel while synchronizing over a set of resources, and furthermore, gives a good reason to use the @and@ operator.
330If the @and@ operator waited for all clauses to be available before running, it is the same as just acquiring those resources consecutively by a sequence of @waituntil@ statements.
331
332As for normal C expressions, the @and@ operator binds more tightly than the @or@.
333To give an @or@ operator higher precedence, parenthesis are used.
334For example, the following @waituntil@ unconditionally waits for @C@ and one of either @A@ or @B@, since the @or@ is given higher precedence via parenthesis.
335\begin{cfa}
336@(@ waituntil( A ) { ... }              // bind tightly to or
337or waituntil( B ) { ... } @)@
338and waituntil( C ) { ... }
339\end{cfa}
340
341The guards in the @waituntil@ statement are called @when@ clauses.
342Each boolean expression inside a @when@ is evaluated \emph{once} before the @waituntil@ statement is run.
343Like Occam's ALT, the guards toggle clauses on and off, where a @waituntil@ clause is only evaluated and waited on if the corresponding guard is @true@.
344In addition, the @waituntil@ guards require some nuance since both @and@ and @or@ operators are supported \see{Section~\ref{s:wu_guards}}.
345When a guard is false and a clause is removed, it can be thought of as removing that clause and its preceding operation from the statement.
346For example, in the following, the two @waituntil@ statements are semantically equivalent.
347
348\begin{lrbox}{\myboxA}
349\begin{cfa}
350when( true ) waituntil( A ) { ... }
351or when( false ) waituntil( B ) { ... }
352and waituntil( C ) { ... }
353\end{cfa}
354\end{lrbox}
355
356\begin{lrbox}{\myboxB}
357\begin{cfa}
358waituntil( A ) { ... }
359and waituntil( C ) { ... }
360
361\end{cfa}
362\end{lrbox}
363
364\begin{tabular}{@{}lcl@{}}
365\usebox\myboxA & $\equiv$ & \usebox\myboxB
366\end{tabular}
367
368The @else@ clause on the @waituntil@ has identical semantics to the @else@ clause in Ada.
369If all resources are not immediately available and there is an @else@ clause, the @else@ clause is run and the thread continues.
370
371\subsection{Type Semantics}
372
373As mentioned, to support interaction with the @waituntil@ statement a type must support the trait in Figure~\ref{f:wu_trait}.
374The @waituntil@ statement expects types to register and unregister themselves via calls to @register_select@ and @unregister_select@, respectively.
375When a resource becomes available, @on_selected@ is run, and if it returns false, the corresponding code block is not run.
376Many types do not need @on_selected@, but it is provided if a type needs to perform work or checks before the resource can be accessed in the code block.
377The register/unregister routines in the trait also return booleans.
378The return value of @register_select@ is @true@, if the resource is immediately available and @false@ otherwise.
379The return value of @unregister_select@ is @true@, if the corresponding code block should be run after unregistration and @false@ otherwise.
380The routine @on_selected@ and the return value of @unregister_select@ are needed to support channels as a resource.
381More detail on channels and their interaction with @waituntil@ appear in Section~\ref{s:wu_chans}.
382
383The trait is used by having a blocking object return a type that supports the @is_selectable@ trait.
384This feature leverages \CFA's ability to overload on return type to select the correct overloaded routine for the @waituntil@ context.
385A selectable type is needed for types that want to support multiple operations such as channels that allow both reading and writing.
386
387\section{\lstinline{waituntil} Implementation}
388
389The @waituntil@ statement is not inherently complex, and Figure~\ref{f:WU_Impl} only shows the basic outline of the @waituntil@ algorithm.
390The complexity comes from the consideration of race conditions and synchronization needed when supporting various primitives.
391The following sections then use examples to fill in details missing in Figure~\ref{f:WU_Impl}.
392The full pseudocode for the @waituntil@ algorithm is presented in Figure~\ref{f:WU_Full_Impl}.
393
394\begin{figure}
395\begin{cfa}
396select_nodes s[N];                                                              $\C[3.25in]{// declare N select nodes}$
397for ( node in s )                                                               $\C{// register nodes}$
398        register_select( resource, node );
399while ( statement predicate not satisfied ) {   $\C{// check predicate}$
400        // block until clause(s) satisfied
401        for ( resource in waituntil statement ) {       $\C{// run true code blocks}$
402                if ( resource is avail ) run code block
403                if ( statement predicate is satisfied ) break;
404        }
405}
406for ( node in s )                                                               $\C{// deregister nodes}\CRT$
407        if ( unregister_select( resource, node ) ) run code block
408\end{cfa}
409\caption{\lstinline{waituntil} Implementation}
410\label{f:WU_Impl}
411\end{figure}
412
413The basic steps of the algorithm are:
414\begin{enumerate}
415\item
416The @waituntil@ statement declares $N$ @select_node@s, one per resource that is being waited on, which stores any @waituntil@ data pertaining to that resource.
417
418\item
419Each @select_node@ is then registered with the corresponding resource.
420
421\item
422The thread executing the @waituntil@ then loops until the statement's predicate is satisfied.
423In each iteration, if the predicate is unsatisfied, the @waituntil@ thread blocks.
424When another thread satisfies a resource clause (\eg sends to a  channel), it unblocks the @waituntil@ thread.
425This thread checks all clauses for completion, and any completed clauses have their code blocks run.
426While checking clause completion, if enough clauses have been run such that the statement predicate is satisfied, the loop exits early.
427
428\item
429Once the thread escapes the loop, the @select_nodes@ are unregistered from the resources.
430\end{enumerate}
431These steps give a basic overview of how the statement works.
432The following sections shed light on the specific changes and provide more implementation detail.
433
434\subsection{Locks}\label{s:wu_locks}
435
436The \CFA runtime supports a number of spinning and blocking locks, \eg semaphore, MCS, futex, Go mutex, spinlock, owner, \etc.
437Many of these locks satisfy the @is_selectable@ trait, and hence, are resources supported by the @waituntil@ statement.
438For example, the following waits until the thread has acquired lock @l1@ or locks @l2@ and @l3@.
439\begin{cfa}
440owner_lock l1, l2, l3;
441waituntil ( l1 ) { ... }
442or waituntil( l2 ) { ... }
443and waituntil( l3 ) { ... }
444\end{cfa}
445Implicitly, the @waituntil@ is calling the lock acquire for each of these locks to establish a position in the lock's queue of waiting threads.
446When the lock schedules this thread, it unblocks and runs the code block associated with the lock and then releases the lock.
447
448In detail, when a thread waits on multiple locks via a @waituntil@, it enqueues a @select_node@ in each of the lock's waiting queues.
449When a @select_node@ reaches the front of the lock's queue and gains ownership, the thread blocked on the @waituntil@ is unblocked.
450Now, the lock is held by the @waituntil@ thread until the code block is executed, and then the node is unregistered, during which the lock is released.
451Immediately releasing the lock prevents the waiting thread from holding multiple locks and potentially introducing a deadlock.
452As such, the only unregistered nodes associated with locks are the ones that have not run.
453
454\subsection{Timeouts}
455
456A timeout for the @waituntil@ statement is a duration passed to \lstinline[deletekeywords={timeout}]{timeout}, \eg:
457\begin{cquote}
458\begin{tabular}{@{}l|l@{}}
459\multicolumn{2}{@{}l@{}}{\lstinline{Duration D1\{ 1`ms \}, D2\{ 2`ms \}, D3\{ 3`ms \};}} \\
460\begin{cfa}[deletekeywords={timeout}]
461waituntil( i << C1 ) {}
462or waituntil( i << C2 ) {}
463or waituntil( i << C3 ) {}
464or waituntil( timeout( D1 ) ) {}
465or waituntil( timeout( D2 ) ) {}
466or waituntil( timeout( D3 ) ) {}
467\end{cfa}
468&
469\begin{cfa}[deletekeywords={timeout}]
470waituntil( i << C1 ) {}
471or waituntil( i << C2 ) {}
472or waituntil( i << C3 ) {}
473or waituntil( min( timeout( D1 ), timeout( D2 ),  timeout( D3 ) ) {}
474
475
476\end{cfa}
477\end{tabular}
478\end{cquote}
479These examples are basically equivalent.
480Here, the multiple timeouts are useful because the durations can change during execution and the separate clauses provide different code blocks if a timeout triggers.
481Multiple timeouts can also be used with @and@ to provide a minimal delay before proceeding.
482In following example, either channels @C1@ or @C2@ must be satisfied but nothing can be done for at least 1 or 3 seconds after the channel read.
483\begin{cfa}[deletekeywords={timeout}]
484waituntil( i << C1 ); and waituntil( timeout( 1`s ) );
485or waituntil( i << C2 ); and waituntil( timeout( 3`s ) );
486\end{cfa}
487If only @C2@ is satisfied, \emph{both} timeout code-blocks trigger.
488Note, the \CFA @waitfor@ statement only provides a single @timeout@ clause because it only supports @or@ semantics.
489
490The \lstinline[deletekeywords={timeout}]{timeout} routine is different from UNIX @sleep@, which blocks for the specified duration and returns the amount of time elapsed since the call started.
491Instead, \lstinline[deletekeywords={timeout}]{timeout} returns a type that supports the @is_selectable@ trait, allowing the type system to select the correct overloaded routine for this context.
492For the @waituntil@, it is more idiomatic for the \lstinline[deletekeywords={timeout}]{timeout} to use the same syntax as other blocking operations instead of having a special language clause.
493
494\subsection{Channels}\label{s:wu_chans}
495
496Channels require more complexity to allow synchronous multiplexing.
497For locks, when an outside thread releases a lock and unblocks the waituntil thread (WUT), the lock's MX property is passed to the WUT (no spinning locks).
498For futures, the outside thread deliveries a value to the future and unblocks any waiting threads, including WUTs.
499In either case, after the WUT unblocks it is safe to execute its the corresponding code block knowing access to the resource is protected by the lock or the read-only state of the future.
500Similarly, for channels, when an outside thread inserts a value into a channel, it must unblock the WUT.
501However, for channels, there is a race condition that poses an issue.
502If the outside thread inserts into the channel and unblocks the WUT, there is a race where another thread can remove the channel data, so after the WUT unblocks and attempts to remove from the buffer, it fails, and the WUT must reblock (busy waiting).
503This scenario is a \gls{toctou} race that needs to be consolidated.
504To close the race, the outside thread must detect this case and insert directly into the left-hand side of the channel expression (@i << chan@) rather than into the channel, and then unblock the WUT.
505Now the unblocked WUT is guaranteed to have a satisfied resource and its code block can safely executed.
506The insertion circumvents the channel buffer via the wait-morphing in the \CFA channel implementation \see{Section~\ref{s:chan_impl}}, allowing @waituntil@ channel unblocking to not be special-cased.
507
508Furthermore, if both @and@ and @or@ operators are used, the @or@ operations stop behaving like exclusive-or due to the race among channel operations, \eg:
509\begin{cfa}
510waituntil( i << A ) {} and waituntil( i << B ) {}
511or waituntil( i << C ) {} and waituntil( i << D ) {}
512\end{cfa}
513If exclusive-or semantics are followed, only the code blocks for @A@ and @B@ are run, or the code blocks for @C@ and @D@.
514However, four outside threads can simultaneously put values into @i@ and attempt to unblock the WUT to run the four code-blocks.
515This case introduces a race with complexity that increases with the size of the @waituntil@ statement.
516However, due to TOCTOU issues, it is impossible to know if all resources are available without acquiring all the internal locks of channels in the subtree of the @waituntil@ clauses.
517This approach is a poor solution for two reasons.
518It is possible that once all the locks are acquired the subtree is not satisfied and the locks must be released.
519This work incurs a high cost for signalling threads and heavily increase contention on internal channel locks.
520Furthermore, the @waituntil@ statement is polymorphic and can support resources that do not have internal locks, which also makes this approach infeasible.
521As such, the exclusive-or semantics is lost when using both @and@ and @or@ operators since it cannot be supported without significant complexity and significantly affects @waituntil@ performance.
522
523It was deemed important that exclusive-or semantics are maintained when only @or@ operators are used, so this situation has been special-cased, and is handled by having all clauses race to set a value \emph{before} operating on the channel.
524Consider the following example where thread 1 is reading and threads 2 and 3 are writing to channels @A@ and @B@ concurrently.
525\begin{cquote}
526\begin{tabular}{@{}l|l|l@{}}
527\multicolumn{3}{@{}l@{}}{\lstinline{channel A, B; // zero size channels}} \\
528thread 1 & thread 2 & thread 3 \\
529\begin{cfa}
530waituntil( i << A ) {}
531or waituntil( i << B ) {}
532\end{cfa}
533&
534\begin{cfa}
535A << 1;
536
537\end{cfa}
538&
539\begin{cfa}
540B << 2;
541
542\end{cfa}
543\end{tabular}
544\end{cquote}
545For thread 1 to have exclusive-or semantics, it must only consume from exactly one of @A@ or @B@.
546As such, thread 2 and 3 must race to establish the winning clause of the @waituntil@ in thread 1.
547This race is consolidated by thread 2 and 3 each attempting to set a pointer to the winning clause's @select_node@ address using \gls{cas}.
548The winner bypasses the channel and inserts into the WUT's left-hand, and signals thread 1.
549The loser continues checking if there is space in the channel, and if so performs the channel insert operation with a possible signal of a waiting remove thread;
550otherwise, if there is no space, the loser blocks.
551It is important the race occurs \emph{before} operating on the channel, because channel actions are different with respect to each thread.
552If the race was consolidated after the operation, both thread 2 and 3 could potentially write into @i@ concurrently.
553
554Channels introduce another interesting implementation issue.
555Supporting both reading and writing to a channel in a @waituntil@ means that one @waituntil@ clause may be the notifier of another @waituntil@ clause.
556This poses a problem when dealing with the special-cased @or@ where the clauses need to win a race to operate on a channel.
557Consider the following example, alongside a described ordering of events to highlight the race.
558\begin{cquote}
559\begin{tabular}{@{}l|l@{}}
560\multicolumn{2}{@{}l@{}}{\lstinline{channel A, B; // zero size channels}} \\
561thread 1 & thread 2 \\
562\begin{cfa}
563waituntil( @i << A@ ) {}
564or waituntil( @i << B@ ) {}
565\end{cfa}
566&
567\begin{cfa}
568waituntil( @B << 2}@ ) {}
569or waituntil( @A << 1@ ) {}
570\end{cfa}
571\end{tabular}
572\end{cquote}
573Assume thread 1 executes first, registers with channel @A@ and proceeds, since it is empty, and then is interrupted before registering with @B@.
574Thread 2 similarly registers with channel @B@, and proceeds, since it does not have space to insert, and then is interrupted before registering with @A@.
575At this point, thread 1 and 2 resume execution.
576There is now a race that must be dealt with on two fronts.
577If thread 1 and 2 only race to the \gls{cas}, \ie a clause in their own @waituntil@, thread 1 can think that it successfully removed from @B@, and thread 2 may think it successfully inserted into @A@, when only one of these operations occurs.
578
579The Go @select@ solves this problem by acquiring all the internal locks of the channels before registering the @select@ on the channels.
580This approach eliminates the race shown above since thread 1 and 2 cannot both be registering at the same time.
581However, this approach cannot be used in \CFA, since the @waituntil@ is polymorphic.
582Not all types in a @waituntil@ have an internal lock, and when using non-channel types acquiring all the locks incurs extra unneeded overhead.
583Instead, this race is consolidated in \CFA in two phases by having an intermediate pending status value for the race.
584This race case is detectable, and if detected, each thread first races to set its own @waituntil@ race pointer to be pending.
585If it succeeds, it then attempts to set the other thread's @waituntil@ race pointer to its success value.
586If either thread successfully sets the the other thread's @waituntil@ race pointer, then the operation can proceed, if not the signalling threads set its own race pointer back to the initial value and repeats.
587This retry mechanism can potentially introduce a livelock, but in practice a livelock here is highly unlikely.
588Furthermore, the likelihood of a livelock here is zero unless the program is in the niche case of having two or more exclusive-or @waituntil@s with two or more clauses in reverse order of priority.
589This livelock case can be fully eliminated using locks like Go, or if a \gls{dcas} instruction is available.
590If any other threads attempt to set a WUT's race pointer and see a pending value, they wait until the value changes before proceeding to ensure that, in the case the WUT fails, the signal is not lost.
591This protocol ensures that signals cannot be lost and that the two races can be resolved in a safe manner.
592\PAB{I bet one of the readers is going to ask you to write the pseudo code for this algorithm.}
593
594Channels in \CFA have exception-based shutdown mechanisms that the @waituntil@ statement needs to support.
595These exception mechanisms are supported through the @on_selected@ routine.
596This routine is needed by channels to detect if they are closed after unblocking in a @waituntil@ statement, to ensure the appropriate behaviour is taken and an exception is thrown.
597
598\subsection{Guards and Statement Predicate}\label{s:wu_guards}
599
600It is trivial to check when a synchronous multiplexing utility is done for the or/xor relationship, since any resource becoming available means that the blocked thread can proceed and the @waituntil@ statement is finished.
601In \uC and \CFA, the \gls{synch_multiplex} mechanism have both an and/or relationship, which make the problem of checking for completion of the statement difficult.
602\PAB{Show an example of why this is difficult.}
603
604In the \uC @_Select@ statement, this problem is solved by constructing a tree of the resources, where the internal nodes are operators and the leaves are booleans storing the state of each resource.
605The internal nodes also store the statuses of the two subtrees beneath them.
606When resources become available, their corresponding leaf node status is modified, which percolates up the tree to update the state of the statement.
607Once the root of the tree has both subtrees marked as @true@ then the statement is complete.
608As an optimization, when the internal nodes are updated, the subtrees marked as @true@ are pruned and not examined again.
609To support statement guards in \uC, the tree prunes a branch if the corresponding guard is false.
610\PAB{Show an example.}
611
612The \CFA @waituntil@ statement blocks a thread until a set of resources have become available that satisfy the underlying predicate.
613The waiting condition of the @waituntil@ statement can be represented as a predicate over the resources, joined by the @waituntil@ operators, where a resource is @true@ if it is available, and @false@ otherwise.
614In \CFA, this representation is used as the mechanism to check if a thread is done waiting on the @waituntil@.
615Leveraging the compiler, a predicate routine is generated per @waituntil@ that when passes the statuses of the resources, returns @true@ when the @waituntil@ is done, and false otherwise.
616To support guards on the \CFA @waituntil@ statement, the status of a resource disabled by a guard is set to a boolean value that ensures that the predicate function behaves as if that resource is no longer part of the predicate.
617\PAB{Show an example.}
618
619\uC's @_Select@, supports operators both inside and outside of the \lstinline[language=uC++]{_Select} clauses.
620In the following example, the code blocks run once their corresponding predicate inside the round braces is satisfied.
621% C_TODO put this is uC++ code style not cfa-style
622\begin{lstlisting}[language=uC++]
623Future_ISM<int> A, B, C, D;
624_Select( A || B && C ) { ... }
625and _Select( D && E ) { ... }
626\end{lstlisting}
627This is more expressive that the @waituntil@ statement in \CFA, allowing the code block for @&&@ to only run after both resources are available.
628
629In \CFA, since the @waituntil@ statement supports more resources than just futures, implementing operators inside clauses is avoided for a few reasons.
630As a motivating example, suppose \CFA supported operators inside clauses as in:
631\begin{cfa}
632owner_lock A, B, C, D;
633waituntil( A && B ) { ... }
634or waituntil( C && D ) { ... }
635\end{cfa}
636If the @waituntil@ acquires each lock as it becomes available, there is a possible deadlock since it is in a hold and wait situation.
637Other semantics are needed to ensure this operation is safe.
638One possibility is to use \CC's @scoped_lock@ approach described in Section~\ref{s:DeadlockAvoidance};
639however, that opens the potential for livelock.
640Another possibility is to use resource ordering similar to \CFA's @mutex@ statement, but that alone is insufficient, if the resource ordering is not used universally.
641Additionally, using resource ordering could conflict with other semantics of the @waituntil@ statement.
642For example, consider if the locks in the example must be acquired in the order @D@, @B@, @C@, @A@ because of other @waituntil@ statements.
643\PAB{I don't understand: If all the locks are available, it becomes complex to both respect the ordering of the \lstinline{waituntil} when choosing which code block to run and also respect the lock ordering of \lstinline{D}, \lstinline{B}, \lstinline{C}, \lstinline{A} at the same time.}
644One other way this could be implemented is to wait until all resources for a given clause are available before proceeding to acquire them, but this also quickly becomes a poor approach.
645This approach does not work due to \gls{toctou} issues;
646it is impossible to ensure that the full set of resources are available without holding them all first.
647Operators inside clauses in \CFA could potentially be implemented with careful circumvention of the problems involved, but it was not deemed an important feature when taking into account the runtime cost need paid to handle this situation.
648The problem of operators inside clauses also becomes a difficult issue to handle when supporting channels.
649It would require some way to ensure channels used with internal operators are modified, if and only if, the corresponding code block is run, but that is not feasible due to reasons described in the exclusive-or portion of Section~\ref{s:wu_chans}.
650
651\subsection{The full \lstinline{waituntil} picture}
652
653Now the details have been discussed, the full pseudocode of the @waituntil@ is presented in Figure~\ref{f:WU_Full_Impl}.
654Some things to note are as follows.
655The @finally@ blocks provide exception-safe \gls{raii} unregistering of nodes, and in particular, the @finally@ inside the innermost loop performs the immediate unregistering required for deadlock-freedom mentioned in Section~\ref{s:wu_locks}.
656The @when_conditions@ array is used to store the boolean result of evaluating each guard at the beginning of the @waituntil@, and it is used to conditionally omit operations on resources with @false@ guards.
657As discussed in Section~\ref{s:wu_chans}, this pseudocode includes conditional code-block execution based on the result of both @on_selected@ and @unregister_select@, which allows the channel implementation to ensure all available channel resources have their corresponding code block run.
658
659\begin{figure}
660\begin{cfa}
661bool when_conditions[N];
662for ( node in s )                                                                       $\C[3.75in]{// evaluate guards}$
663        if ( node has guard )
664                when_conditions[node] = node_guard;
665        else
666                when_conditions[node] = true;
667
668select_nodes s[N];                                                                      $\C{// declare N select nodes}$
669try {
670        for ( node in s )                                                               $\C{// register nodes}$
671                if ( when_conditions[node] )
672                        register_select( resource, node );
673
674        // ... set statuses for nodes with when_conditions[node] == false ...
675
676        while ( statement predicate not satisfied ) {   $\C{// check predicate}$
677                // block
678                for ( resource in waituntil statement ) {       $\C{// run true code blocks}$
679                        if ( statement predicate is satisfied ) break;
680                        if ( resource is avail )
681                                try {
682                                        if( on_selected( resource ) )   $\C{// conditionally run block}$
683                                                run code block
684                                } finally                                                       $\C{// for exception safety}$
685                                        unregister_select( resource, node ); $\C{// immediate unregister}$
686                }
687        }
688} finally {                                                                                     $\C{// for exception safety}$
689        for ( registered nodes in s )                                   $\C{// deregister nodes}$
690                if ( when_conditions[node] && unregister_select( resource, node )
691                                && on_selected( resource ) )
692                        run code block                                                  $\C{// run code block upon unregister}\CRT$
693}
694\end{cfa}
695\caption{Full \lstinline{waituntil} Pseudocode Implementation}
696\label{f:WU_Full_Impl}
697\end{figure}
698
699\section{Waituntil Performance}
700
701Similar facilities to @waituntil@ are discussed at the start of this chapter in C, Ada, Rust, \CC, and OCaml.
702However, these facilities are either not meaningful or feasible to benchmark against.
703The UNIX @select@ and related utilities are not comparable since they are system calls that go into the kernel and operate on file descriptors, whereas the @waituntil@ exists solely in user space.
704Ada's @select@ only operates on methods, which is done in \CFA via the @waitfor@ utility so it is not meaningful to benchmark against the @waituntil@, which cannot wait on the same resource.
705Rust and \CC only offer a busy-wait based approach, which is not comparable to a blocking approach.
706OCaml's @select@ waits on channels that are not comparable with \CFA and Go channels, so OCaml @select@ is not benchmarked against Go's @select@ and \CFA's @waituntil@.
707
708The two \gls{synch_multiplex} utilities that are in the realm of comparability with the \CFA @waituntil@ statement are the Go @select@ statement and the \uC @_Select@ statement.
709As such, two microbenchmarks are presented, one for Go and one for \uC to contrast the systems.
710Given the differences in features, polymorphism, and expressibility between @waituntil@ and @select@, and @_Select@, the aim of the microbenchmarking in this chapter is to show that these implementations lie in the same realm of performance, not to pick a winner.
711
712\subsection{Channel Benchmark}
713
714The channel multiplexing microbenchmarks compare \CFA's @waituntil@ and Go's \lstinline[language=Go]{select}, where the resource being waited on is a set of channels.
715The basic structure of the microbenchmark has the number of cores split evenly between producer and consumer threads, \ie, with 8 cores there are 4 producer and 4 consumer threads.
716The number of resource clauses $C$ is also varied across 2, 4, and 8 clauses, where each clause has different channel that is waits on.
717Each producer and consumer repeatedly waits to either produce or consume from one of the $C$ clauses and respective channels.
718For example, in \CFA syntax, the work loop in the consumer main with $C = 4$ clauses is:
719\begin{cfa}
720for ()
721        waituntil( val << chans[0] ); or waituntil( val << chans[1] );
722        or waituntil( val << chans[2] ); or waituntil( val << chans[3] );
723\end{cfa}
724A successful consumption is counted as a channel operation, and the throughput of these operations is measured over 10 seconds.
725The first microbenchmark measures throughput of the producers and consumer synchronously waiting on the channels and the second has the threads asynchronously wait on the channels.
726The results are shown in Figures~\ref{f:select_contend_bench} and~\ref{f:select_spin_bench} respectively.
727
728\begin{figure}
729        \centering
730        \captionsetup[subfloat]{labelfont=footnotesize,textfont=footnotesize}
731        \subfloat[AMD]{
732                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Contend_2.pgf}}
733        }
734        \subfloat[Intel]{
735                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Contend_2.pgf}}
736        }
737        \bigskip
738
739        \subfloat[AMD]{
740                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Contend_4.pgf}}
741        }
742        \subfloat[Intel]{
743                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Contend_4.pgf}}
744        }
745        \bigskip
746
747        \subfloat[AMD]{
748                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Contend_8.pgf}}
749        }
750        \subfloat[Intel]{
751                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Contend_8.pgf}}
752        }
753        \caption{The channel synchronous multiplexing benchmark comparing Go select and \CFA \lstinline{waituntil} statement throughput (higher is better).}
754        \label{f:select_contend_bench}
755\end{figure}
756
757\begin{figure}
758        \centering
759        \captionsetup[subfloat]{labelfont=footnotesize,textfont=footnotesize}
760        \subfloat[AMD]{
761                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Spin_2.pgf}}
762        }
763        \subfloat[Intel]{
764                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Spin_2.pgf}}
765        }
766        \bigskip
767
768        \subfloat[AMD]{
769                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Spin_4.pgf}}
770        }
771        \subfloat[Intel]{
772                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Spin_4.pgf}}
773        }
774        \bigskip
775
776        \subfloat[AMD]{
777                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Spin_8.pgf}}
778        }
779        \subfloat[Intel]{
780                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Spin_8.pgf}}
781        }
782        \caption{The asynchronous multiplexing channel benchmark comparing Go select and \CFA \lstinline{waituntil} statement throughput (higher is better).}
783        \label{f:select_spin_bench}
784\end{figure}
785
786Both Figures~\ref{f:select_contend_bench} and~\ref{f:select_spin_bench} have similar results when comparing @select@ and @waituntil@.
787In the AMD benchmarks, the performance is very similar as the number of cores scale.
788The AMD machine has been observed to have higher caching contention cost, which creates on a bottleneck on the channel locks, which results in similar scaling between \CFA and Go.
789At low cores, Go has significantly better performance, which is likely due to an optimization in their scheduler.
790Go heavily optimizes thread handoffs on their local run-queue, which can result in very good performance for low numbers of threads which are parking/unparking each other~\cite{go:sched}.
791In the Intel benchmarks, \CFA performs better than Go as the number of cores scale and as the number of clauses scale.
792This is likely due to Go's implementation choice of acquiring all channel locks when registering and unregistering channels on a @select@.
793Go then has to hold a lock for every channel, so it follows that this results in worse performance as the number of channels increase.
794In \CFA, since races are consolidated without holding all locks, it scales much better both with cores and clauses since more work can occur in parallel.
795This scalability difference is more significant on the Intel machine than the AMD machine since the Intel machine has been observed to have lower cache contention costs.
796
797The Go approach of holding all internal channel locks in the select has some additional drawbacks.
798This approach results in some pathological cases where Go's system throughput on channels can greatly suffer.
799Consider the case where there are two channels, @A@ and @B@.
800There are both a producer thread and a consumer thread, @P1@ and @C1@, selecting both @A@ and @B@.
801Additionally, there is another producer and another consumer thread, @P2@ and @C2@, that are both operating solely on @B@.
802Compared to \CFA this setup results in significantly worse performance since @P2@ and @C2@ cannot operate in parallel with @P1@ and @C1@ due to all locks being acquired.
803This case may not be as pathological as it may seem.
804If the set of channels belonging to a select have channels that overlap with the set of another select, they lose the ability to operate on their select in parallel.
805The implementation in \CFA only ever holds a single lock at a time, resulting in better locking granularity.
806Comparison of this pathological case is shown in Table~\ref{t:pathGo}.
807The AMD results highlight the worst case scenario for Go since contention is more costly on this machine than the Intel machine.
808
809\begin{table}[t]
810\centering
811\setlength{\extrarowheight}{2pt}
812\setlength{\tabcolsep}{5pt}
813
814\caption{Throughput (channel operations per second) of \CFA and Go for a pathologically bad case for contention in Go's select implementation}
815\label{t:pathGo}
816\begin{tabular}{*{5}{r|}r}
817        & \multicolumn{1}{c|}{\CFA} & \multicolumn{1}{c@{}}{Go} \\
818        \hline
819        AMD             & \input{data/nasus_Order} \\
820        \hline
821        Intel   & \input{data/pyke_Order}
822\end{tabular}
823\end{table}
824
825Another difference between Go and \CFA is the order of clause selection when multiple clauses are available.
826Go "randomly" selects a clause, but \CFA chooses the clause in the order they are listed~\cite{go:select}.
827This \CFA design decision allows users to set implicit priorities, which can result in more predictable behaviour, and even better performance in certain cases, such as the case shown in  Table~\ref{t:pathGo}.
828If \CFA didn't have priorities, the performance difference in Table~\ref{t:pathGo} would be less significant since @P1@ and @C1@ would try to compete to operate on @B@ more often with random selection.
829
830\subsection{Future Benchmark}
831The future benchmark compares \CFA's @waituntil@ with \uC's @_Select@, with both utilities waiting on futures.
832Both \CFA's @waituntil@ and \uC's @_Select@ have very similar semantics, however @_Select@ can only wait on futures, whereas the @waituntil@ is polymorphic.
833They both support @and@ and @or@ operators, but the underlying implementation of the operators differs between @waituntil@ and @_Select@.
834The @waituntil@ statement checks for statement completion using a predicate function, whereas the @_Select@ statement maintains a tree that represents the state of the internal predicate.
835
836\begin{figure}
837        \centering
838        \subfloat[AMD Future Synchronization Benchmark]{
839                \resizebox{0.5\textwidth}{!}{\input{figures/nasus_Future.pgf}}
840                \label{f:futureAMD}
841        }
842        \subfloat[Intel Future Synchronization Benchmark]{
843                \resizebox{0.5\textwidth}{!}{\input{figures/pyke_Future.pgf}}
844                \label{f:futureIntel}
845        }
846        \caption{\CFA \lstinline{waituntil} and \uC \lstinline{_Select} statement throughput synchronizing on a set of futures with varying wait predicates (higher is better).}
847        \caption{}
848        \label{f:futurePerf}
849\end{figure}
850
851This microbenchmark aims to measure the impact of various predicates on the performance of the @waituntil@ and @_Select@ statements.
852This benchmark and section does not try to directly compare the @waituntil@ and @_Select@ statements since the performance of futures in \CFA and \uC differ by a significant margin, making them incomparable.
853Results of this benchmark are shown in Figure~\ref{f:futurePerf}.
854Each set of columns is marked with a name representing the predicate for that set of columns.
855The predicate name and corresponding @waituntil@ statement is shown below:
856
857\begin{cfa}
858#ifdef OR
859waituntil( A ) { get( A ); }
860or waituntil( B ) { get( B ); }
861or waituntil( C ) { get( C ); }
862#endif
863#ifdef AND
864waituntil( A ) { get( A ); }
865and waituntil( B ) { get( B ); }
866and waituntil( C ) { get( C ); }
867#endif
868#ifdef ANDOR
869waituntil( A ) { get( A ); }
870and waituntil( B ) { get( B ); }
871or waituntil( C ) { get( C ); }
872#endif
873#ifdef ORAND
874(waituntil( A ) { get( A ); }
875or waituntil( B ) { get( B ); }) // brackets create higher precedence for or
876and waituntil( C ) { get( C ); }
877#endif
878\end{cfa}
879
880In Figure~\ref{f:futurePerf}, the @OR@ column for \CFA is more performant than the other \CFA predicates, likely due to the special-casing of @waituntil@ statements with only @or@ operators.
881For both \uC and \CFA the @AND@ column is the least performant, which is expected since all three futures need to be fulfilled for each statement completion, unlike any of the other operators.
882Interestingly, \CFA has lower variation across predicates on the AMD (excluding the special OR case), whereas \uC has lower variation on the Intel.
Note: See TracBrowser for help on using the repository browser.