source: doc/theses/colby_parsons_MMAth/text/CFA_concurrency.tex @ 59c05958

ADTast-experimental
Last change on this file since 59c05958 was 9363b1b, checked in by caparsons <caparson@…>, 19 months ago

removed code style and refactored to use cfa code style

  • Property mode set to 100644
File size: 1.9 KB
Line 
1\chapter{Concurrency in \CFA}\label{s:cfa_concurrency}
2
3The groundwork for concurrency in \CFA was laid by Thierry Delisle in his Master's Thesis\cite{Delisle18}.
4In that work he introduced coroutines, user level threading, and monitors.
5Not listed in that work were the other concurrency features that were needed as building blocks, such as locks, futures, and condition variables which he also added to \CFA.
6
7\section{Threading Model}\label{s:threading}
8\CFA has user level threading and supports a $M:N$ threading model where $M$ user threads are scheduled on $N$ cores, where both $M$ and $N$ can be explicitly set by the user.
9Cores are used by a program by creating instances of a \code{processor} struct.
10User threads types are defined using the \code{thread} keyword, in the place where a \code{struct} keyword is typically used.
11For each thread type a corresponding main must be defined, which is where the thread starts running once it is created.
12Listing~\ref{l:cfa_thd_init} shows an example of processor and thread creation.
13When processors are added, they are added alongside the existing processor given to each program.
14Thus if you want $N$ processors you need to allocate $N-1$.
15To join a thread the thread must be deallocated, either deleted if it is allocated on the heap, or go out of scope if stack allocated.
16The thread performing the deallocation will wait for the thread being deallocated to terminate before the deallocation can occur.
17A thread terminates by returning from the main routine where it starts.
18
19\begin{cfa}[tabsize=3,caption={\CFA user thread and processor creation},label={l:cfa_thd_init}]
20
21thread my_thread {}     // user thread type
22void main( my_thread & this ) { // thread start routine
23    printf("Hello threading world\n");
24}
25
26int main() {
27    // add 2 processors, now 3 total
28    processor p[2];   
29    {
30        my_thread t1;
31        my_thread t2;
32    } // waits for threads to end before going out of scope
33}
34
35\end{cfa}
Note: See TracBrowser for help on using the repository browser.