source: src/libcfa/concurrency/threads.c @ 0c92c9f

aaron-thesisarm-ehcleanup-dtorsdeferred_resndemanglerjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerresolv-newwith_gc
Last change on this file since 0c92c9f was 0c92c9f, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

Cleaned-up threading code and added temporary test for threads (single core)

  • Property mode set to 100644
File size: 3.3 KB
Line 
1//                              -*- Mode: CFA -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// threads.c --
9//
10// Author           : Thierry Delisle
11// Created On       : Tue Jan 17 12:27:26 2016
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count     : 0
15//
16
17#include "threads"
18
19#include "kernel"
20#include "libhdr.h"
21
22#define __CFA_INVOKE_PRIVATE__
23#include "invoke.h"
24
25extern "C" {
26        #include <stddef.h>
27}
28
29extern processor * get_this_processor();
30
31//-----------------------------------------------------------------------------
32// Forward declarations
33forall( dtype T | is_thread(T) )
34void start( T* this );
35
36forall( dtype T | is_thread(T) )
37void stop( T* this );
38
39//-----------------------------------------------------------------------------
40// Thread ctors and dtors
41
42void ?{}(thread* this) {
43        (&this->c){};
44        this->c.name = "Anonymous Coroutine";
45        (&this->lock){};
46        this->next = NULL;
47}
48
49void ^?{}(thread* this) {
50        ^(&this->c){};
51}
52
53forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T*); } )
54void ?{}( scoped(T)* this ) {
55        (&this->handle){};
56        start(&this->handle);
57}
58
59forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T*, P); } )
60void ?{}( scoped(T)* this, P params ) {
61        (&this->handle){ params };
62        start(&this->handle);
63}
64
65forall( dtype T | sized(T) | is_thread(T) | { void ^?{}(T*); } )
66void ^?{}( scoped(T)* this ) {
67        stop(&this->handle);
68        ^(&this->handle){};
69}
70
71//-----------------------------------------------------------------------------
72// Starting and stopping threads
73extern "C" {
74      forall(dtype T | is_thread(T))
75      void CtxInvokeThread(T * this);
76}
77
78extern void thread_schedule( thread * );
79
80forall( dtype T | is_thread(T) )
81void start( T* this ) {
82        coroutine* thrd_c = get_coroutine(this);
83        thread*  thrd_h = get_thread   (this);
84        thrd_c->last = this_coroutine();
85        get_this_processor()->current_coroutine = thrd_c;
86
87        LIB_DEBUG_PRINTF("Thread start : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
88
89        create_stack(&thrd_c->stack, thrd_c->stack.size);
90        CtxStart(this, CtxInvokeThread);
91        CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context );
92
93        LIB_DEBUG_PRINTF("Thread started : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
94
95        thread_schedule(thrd_h);
96}
97
98forall( dtype T | is_thread(T) )
99void stop( T* this ) {
100        thread*  thrd = get_thread(this);
101        if( thrd->c.notHalted ) {
102                lock( &thrd->lock );
103        }
104}
105
106void yield( void ) {
107        thread_schedule( this_thread() );
108        suspend();
109}
110
111void ThreadCtxSwitch(coroutine* src, coroutine* dst) {
112        dst->last = src;
113
114        // set state of current coroutine to inactive
115        src->state = Inactive;
116
117        // set new coroutine that task is executing
118        get_this_processor()->current_coroutine = dst; 
119
120        // context switch to specified coroutine
121        CtxSwitch( src->stack.context, dst->stack.context );
122        // when CtxSwitch returns we are back in the src coroutine
123
124        // set state of new coroutine to active
125        src->state = Active;
126}
127
128// C Helper to signal the termination of a thread
129// Used in invoke.c
130extern "C" {
131        void __thread_signal_termination( thread * this ) {
132                this->c.state = Halt;
133                this->c.notHalted = false;
134                unlock( &this->lock );
135        }
136}
137
138// Local Variables: //
139// mode: c //
140// tab-width: 4 //
141// End: //
Note: See TracBrowser for help on using the repository browser.