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

ADT arm-eh ast-experimental enum forall-pointer-decay jacob/cs343-translation new-ast-unique-expr pthread-emulation qualifiedEnum
Last change on this file since a33c113 was ecfd758, checked in by Andrew Beach <ajbeach@…>, 4 years ago

Major exception update, seperating type-ids from virtual tables. The major interface changes are done. There is a regression of ?Cancelled(T) to Some?Cancelled. There is some bits of code for the new verion of the ?Cancelled(T) interface already there. Not connected yet but I just reached the limit of what I wanted to do in one commit and then spent over a day cleaning up, so it will replace Some?Cancelled in a future commit.

  • Property mode set to 100644
File size: 5.1 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 = 0x0D15EA5E0D15EA5Ep;
44 #endif
45
46 seqable.next = 0p;
47 seqable.back = 0p;
48
49 node.next = 0p;
50 node.prev = 0p;
51 doregister(curr_cluster, this);
52
53 monitors{ &self_mon_p, 1, (fptr_t)0 };
54}
55
56void ^?{}($thread& this) with( this ) {
57 #if defined( __CFA_WITH_VERIFY__ )
58 canary = 0xDEADDEADDEADDEADp;
59 #endif
60 unregister(curr_cluster, this);
61 ^self_cor{};
62}
63
64EHM_VIRTUAL_TABLE(SomeThreadCancelled, std_thread_cancelled);
65
66forall(T &)
67void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
68 dst->virtual_table = src->virtual_table;
69 dst->the_thread = src->the_thread;
70 dst->the_exception = src->the_exception;
71}
72
73forall(T &)
74const char * msg(ThreadCancelled(T) *) {
75 return "ThreadCancelled(...)";
76}
77
78forall(T &)
79static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
80 // Improve this error message, can I do formatting?
81 abort( "Unhandled thread cancellation.\n" );
82}
83
84static void default_thread_cancel_handler(SomeThreadCancelled & ) {
85 // Improve this error message, can I do formatting?
86 abort( "Unhandled thread cancellation.\n" );
87}
88
89forall(T & | is_thread(T) | IS_EXCEPTION(SomeThreadCancelled))
90void ?{}( thread_dtor_guard_t & this,
91 T & thrd, void(*cancelHandler)(SomeThreadCancelled &)) {
92 $monitor * m = get_monitor(thrd);
93 $thread * desc = get_thread(thrd);
94
95 // Setup the monitor guard
96 void (*dtor)(T& mutex this) = ^?{};
97 bool join = cancelHandler != (void(*)(SomeThreadCancelled&))0;
98 (this.mg){&m, (void(*)())dtor, join};
99
100
101 /* paranoid */ verifyf( Halted == desc->state || Cancelled == desc->state, "Expected thread to be Halted or Cancelled, was %d\n", (int)desc->state );
102
103 // After the guard set-up and any wait, check for cancellation.
104 struct _Unwind_Exception * cancellation = desc->self_cor.cancellation;
105 if ( likely( 0p == cancellation ) ) {
106 return;
107 } else if ( Cancelled == desc->state ) {
108 return;
109 }
110 desc->state = Cancelled;
111 void(*defaultResumptionHandler)(SomeThreadCancelled &) =
112 join ? cancelHandler : default_thread_cancel_handler;
113
114 // TODO: Remove explitate vtable set once trac#186 is fixed.
115 SomeThreadCancelled except;
116 except.virtual_table = &std_thread_cancelled;
117 except.the_thread = &thrd;
118 except.the_exception = __cfaehm_cancellation_exception( cancellation );
119 // Why is this cast required?
120 throwResume (SomeThreadCancelled &)except;
121
122 except.the_exception->virtual_table->free( except.the_exception );
123 free( cancellation );
124 desc->self_cor.cancellation = 0p;
125}
126
127void ^?{}( thread_dtor_guard_t & this ) {
128 ^(this.mg){};
129}
130
131//-----------------------------------------------------------------------------
132// Starting and stopping threads
133forall( T & | is_thread(T) )
134void __thrd_start( T & this, void (*main_p)(T &) ) {
135 $thread * this_thrd = get_thread(this);
136
137 disable_interrupts();
138 __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
139
140 this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
141 /* paranoid */ verify( this_thrd->context.SP );
142
143 __schedule_thread( this_thrd );
144 enable_interrupts( __cfaabi_dbg_ctx );
145}
146
147//-----------------------------------------------------------------------------
148// Support for threads that don't ues the thread keyword
149forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
150void ?{}( scoped(T)& this ) with( this ) {
151 handle{};
152 __thrd_start(handle, main);
153}
154
155forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
156void ?{}( scoped(T)& this, P params ) with( this ) {
157 handle{ params };
158 __thrd_start(handle, main);
159}
160
161forall( T & | sized(T) | is_thread(T) )
162void ^?{}( scoped(T)& this ) with( this ) {
163 ^handle{};
164}
165
166//-----------------------------------------------------------------------------
167forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(SomeThreadCancelled))
168T & join( T & this ) {
169 thread_dtor_guard_t guard = { this, defaultResumptionHandler };
170 return this;
171}
172
173uint64_t thread_rand() {
174 disable_interrupts();
175 uint64_t ret = __tls_rand();
176 enable_interrupts( __cfaabi_dbg_ctx );
177 return ret;
178}
179
180// Local Variables: //
181// mode: c //
182// tab-width: 4 //
183// End: //
Note: See TracBrowser for help on using the repository browser.