- Timestamp:
- Sep 7, 2023, 10:05:20 AM (13 months ago)
- Branches:
- master
- Children:
- 154672d
- Parents:
- 92d8cda
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
doc/theses/colby_parsons_MMAth/text/CFA_concurrency.tex
r92d8cda r79b05224 1 1 \chapter{Concurrency in \CFA}\label{s:cfa_concurrency} 2 2 3 The groundwork for concurrency in \CFA was laid by Thierry Delisle in his Master's Thesis~\cite{Delisle18}. 4 In that work, he introduced generators, coroutines, monitors, and user-level threading. 5 Not listed in that work were basic concurrency features needed as building blocks, such as locks, futures, and condition variables , which he also added to \CFA.3 The groundwork for concurrency in \CFA was laid by Thierry Delisle in his Master's Thesis~\cite{Delisle18}. 4 In that work, he introduced generators, coroutines, monitors, and user-level threading. 5 Not listed in that work were basic concurrency features needed as building blocks, such as locks, futures, and condition variables. 6 6 7 7 \section{Threading Model}\label{s:threading} 8 \CFA provides user-level threading and supports an $M$:$N$ threading model where $M$ user threads are scheduled on $N$ kernel threads, where both $M$ and $N$ can be explicitly set by the user.9 Kernel threads are created by declaring a @processor@ structure.10 User-thread types are defined by creating a @thread@ aggregate-type, \ie replace @struct@ with @thread@.11 For each thread type a corresponding @main@ routine must be defined, which is where the thread starts running once it is created.12 Examples of \CFA user thread and processor creation are shown in \VRef[Listing]{l:cfa_thd_init}.13 8 9 \CFA provides user-level threading and supports an $M$:$N$ threading model where $M$ user threads are scheduled on $N$ kernel threads and both $M$ and $N$ can be explicitly set by the programmer. 10 Kernel threads are created by declaring processor objects; 11 user threads are created by declaring a thread objects. 12 \VRef[Listing]{l:cfa_thd_init} shows a typical examples of creating a \CFA user-thread type, and then as declaring processor ($N$) and thread objects ($M$). 14 13 \begin{cfa}[caption={Example of \CFA user thread and processor creation},label={l:cfa_thd_init}] 15 @thread@ my_thread {...}; $\C{// user thread type}$ 16 void @main@( my_thread & this ) { $\C{// thread start routine}$ 14 @thread@ my_thread { $\C{// user thread type (like structure}$ 15 ... // arbitrary number of field declarations 16 }; 17 void @main@( @my_thread@ & this ) { $\C{// thread start routine}$ 17 18 sout | "Hello threading world"; 18 19 } 19 20 int main() { 20 int main() { $\C{// program starts with a processor (kernel thread)}$ 21 21 @processor@ p[2]; $\C{// add 2 processors = 3 total with starting processor}$ 22 22 { 23 my_thread t[2], * t3 = new(); $\C{// create 3 user threads, running in main routine}$23 @my_thread@ t[2], * t3 = new(); $\C{// create 3 user threads, running in routine main}$ 24 24 ... // execute concurrently 25 25 delete( t3 ); $\C{// wait for thread to end and deallocate}$ 26 26 } // wait for threads to end and deallocate 27 } 27 } // deallocate additional kernel threads 28 28 \end{cfa} 29 30 When processors are added, they are added alongside the existing processor given to each program. 31 Thus, for $N$ processors, allocate $N-1$ processors. 32 A thread is implicitly joined at deallocation, either implicitly at block exit for stack allocation or explicitly at @delete@ for heap allocation. 33 The thread performing the deallocation must wait for the thread to terminate before the deallocation can occur. 29 A thread type is are defined using the aggregate kind @thread@. 30 For each thread type, a corresponding @main@ routine must be defined, which is where the thread starts running once when a thread object are is created. 31 The @processor@ declaration adds addition kernel threads alongside the existing processor given to each program. 32 Thus, for $N$ processors, allocate $N-1$ processors. 33 A thread is implicitly joined at deallocation, either implicitly at block exit for stack allocation or explicitly at @delete@ for heap allocation. 34 The thread performing the deallocation must wait for the thread to terminate before the deallocation can occur. 34 35 A thread terminates by returning from the main routine where it starts. 35 36 36 \section{Existing Concurrency Features} 37 \section{Existing and New Concurrency Features} 38 37 39 \CFA currently provides a suite of concurrency features including futures, locks, condition variables, generators, coroutines, monitors. 38 40 Examples of these features are omitted as most of them are the same as their counterparts in other languages. 39 41 It is worthwhile to note that all concurrency features added to \CFA are made to be compatible each other. 40 The laundry list of features above and the ones introduced in this thesis can be used in the same program without issue. 42 The laundry list of features above and the ones introduced in this thesis can be used in the same program without issue, and the features are designed to interact in meaningful ways. 43 For example, a thread can inteact with a monitor, which can interact with a coroutine, which can interact with a generator. 41 44 42 45 Solving concurrent problems requires a diverse toolkit.
Note: See TracChangeset
for help on using the changeset viewer.