source: libcfa/src/concurrency/thread.cfa @ cdacb73

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since cdacb73 was e873838, checked in by Thierry Delisle <tdelisle@…>, 4 years ago

Removed unpark and added support for unpark from the kernel (removing the distinction between the two

  • Property mode set to 100644
File size: 4.5 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// thread.c --
8//
9// Author           : Thierry Delisle
10// Created On       : Tue Jan 17 12:27:26 2017
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Wed Dec  4 09:17:49 2019
13// Update Count     : 9
14//
15
16#define __cforall_thread__
17
18#include "thread.hfa"
19
20#include "kernel_private.hfa"
21#include "exception.hfa"
22
23#define __CFA_INVOKE_PRIVATE__
24#include "invoke.h"
25
26//-----------------------------------------------------------------------------
27// Thread ctors and dtors
28void ?{}($thread & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
29        context{ 0p, 0p };
30        self_cor{ name, storage, storageSize };
31        ticket = TICKET_RUNNING;
32        state = Start;
33        preempted = __NO_PREEMPTION;
34        curr_cor = &self_cor;
35        self_mon.owner = &this;
36        self_mon.recursion = 1;
37        self_mon_p = &self_mon;
38        curr_cluster = &cl;
39        link.next = 0p;
40        link.prev = 0p;
41        link.preferred = -1;
42        #if defined( __CFA_WITH_VERIFY__ )
43                canary = 0x0D15EA5E0D15EA5E;
44        #endif
45
46        node.next = 0p;
47        node.prev = 0p;
48        doregister(curr_cluster, this);
49
50        monitors{ &self_mon_p, 1, (fptr_t)0 };
51}
52
53void ^?{}($thread& this) with( this ) {
54        #if defined( __CFA_WITH_VERIFY__ )
55                canary = 0xDEADDEADDEADDEAD;
56        #endif
57        unregister(curr_cluster, this);
58        ^self_cor{};
59}
60
61FORALL_DATA_INSTANCE(ThreadCancelled, (dtype thread_t), (thread_t))
62
63forall(dtype T)
64void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
65        dst->virtual_table = src->virtual_table;
66        dst->the_thread = src->the_thread;
67        dst->the_exception = src->the_exception;
68}
69
70forall(dtype T)
71const char * msg(ThreadCancelled(T) *) {
72        return "ThreadCancelled";
73}
74
75forall(dtype T)
76static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
77        abort( "Unhandled thread cancellation.\n" );
78}
79
80forall(dtype T | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T)))
81void ?{}( thread_dtor_guard_t & this,
82                T & thrd, void(*defaultResumptionHandler)(ThreadCancelled(T) &)) {
83        $monitor * m = get_monitor(thrd);
84        void (*dtor)(T& mutex this) = ^?{};
85        bool join = defaultResumptionHandler != (void(*)(ThreadCancelled(T)&))0;
86        (this.mg){&m, (void(*)())dtor, join};
87
88        // After the guard set-up and any wait, check for cancellation.
89        $thread * desc = get_thread(thrd);
90        struct _Unwind_Exception * cancellation = desc->self_cor.cancellation;
91        if ( likely( 0p == cancellation ) ) {
92                return;
93        } else if ( Cancelled == desc->state ) {
94                return;
95        }
96        desc->state = Cancelled;
97        if (!join) {
98                defaultResumptionHandler = default_thread_cancel_handler;
99        }
100
101        ThreadCancelled(T) except;
102        // TODO: Remove explitate vtable set once trac#186 is fixed.
103        except.virtual_table = &get_exception_vtable(&except);
104        except.the_thread = &thrd;
105        except.the_exception = __cfaehm_cancellation_exception( cancellation );
106        throwResume except;
107
108        except.the_exception->virtual_table->free( except.the_exception );
109        free( cancellation );
110        desc->self_cor.cancellation = 0p;
111}
112
113void ^?{}( thread_dtor_guard_t & this ) {
114        ^(this.mg){};
115}
116
117//-----------------------------------------------------------------------------
118// Starting and stopping threads
119forall( dtype T | is_thread(T) )
120void __thrd_start( T & this, void (*main_p)(T &) ) {
121        $thread * this_thrd = get_thread(this);
122
123        disable_interrupts();
124        __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
125
126        this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
127        verify( this_thrd->context.SP );
128
129        __schedule_thread( this_thrd );
130        enable_interrupts( __cfaabi_dbg_ctx );
131}
132
133//-----------------------------------------------------------------------------
134// Support for threads that don't ues the thread keyword
135forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
136void ?{}( scoped(T)& this ) with( this ) {
137        handle{};
138        __thrd_start(handle, main);
139}
140
141forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
142void ?{}( scoped(T)& this, P params ) with( this ) {
143        handle{ params };
144        __thrd_start(handle, main);
145}
146
147forall( dtype T | sized(T) | is_thread(T) )
148void ^?{}( scoped(T)& this ) with( this ) {
149        ^handle{};
150}
151
152//-----------------------------------------------------------------------------
153forall(dtype T | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T)))
154T & join( T & this ) {
155        thread_dtor_guard_t guard = { this, defaultResumptionHandler };
156        return this;
157}
158
159// Local Variables: //
160// mode: c //
161// tab-width: 4 //
162// End: //
Note: See TracBrowser for help on using the repository browser.