source: libcfa/src/concurrency/thread.cfa @ 9cc3a18

arm-ehjacob/cs343-translationnew-ast-unique-expr
Last change on this file since 9cc3a18 was 9cc3a18, checked in by Thierry Delisle <tdelisle@…>, 6 months ago

Major clean-up before attempting to add new scheduler

  • Property mode set to 100644
File size: 5.0 KB
RevLine 
[78b3f52]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//
[75a17f1]7// thread.c --
[78b3f52]8//
9// Author           : Thierry Delisle
[f07e037]10// Created On       : Tue Jan 17 12:27:26 2017
[6b0b624]11// Last Modified By : Peter A. Buhr
[121be3e]12// Last Modified On : Wed Dec  4 09:17:49 2019
13// Update Count     : 9
[78b3f52]14//
15
[2026bb6]16#define __cforall_thread__
17
[58b6d1b]18#include "thread.hfa"
[78b3f52]19
[73abe95]20#include "kernel_private.hfa"
[ab8c6a6]21#include "exception.hfa"
[8118303]22
23#define __CFA_INVOKE_PRIVATE__
24#include "invoke.h"
25
26//-----------------------------------------------------------------------------
27// Thread ctors and dtors
[ac2b598]28void ?{}($thread & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
[121be3e]29        context{ 0p, 0p };
[de6319f]30        self_cor{ name, storage, storageSize };
[6a77224]31        ticket = TICKET_RUNNING;
[e8e457e]32        state = Start;
[3381ed7]33        preempted = __NO_PREEMPTION;
[82c948c]34        curr_cor = &self_cor;
[65deb18]35        self_mon.owner = &this;
36        self_mon.recursion = 1;
37        self_mon_p = &self_mon;
[de6319f]38        curr_cluster = &cl;
[b798713]39        link.next = 0p;
40        link.prev = 0p;
[b4b63e8]41        #if defined( __CFA_WITH_VERIFY__ )
[ac12f1f]42                canary = 0x0D15EA5E0D15EA5Ep;
[b4b63e8]43        #endif
[de94a60]44
[c131a02]45        seqable.next = 0p;
46        seqable.back = 0p;
47
[121be3e]48        node.next = 0p;
49        node.prev = 0p;
[a1a17a7]50        doregister(curr_cluster, this);
[5ea06d6]51
[65deb18]52        monitors{ &self_mon_p, 1, (fptr_t)0 };
[8118303]53}
54
[ac2b598]55void ^?{}($thread& this) with( this ) {
[b4b63e8]56        #if defined( __CFA_WITH_VERIFY__ )
[ac12f1f]57                canary = 0xDEADDEADDEADDEADp;
[b4b63e8]58        #endif
[a1a17a7]59        unregister(curr_cluster, this);
[65deb18]60        ^self_cor{};
[8118303]61}
62
[ecfd758]63EHM_VIRTUAL_TABLE(SomeThreadCancelled, std_thread_cancelled);
[ab8c6a6]64
[fd54fef]65forall(T &)
[ab8c6a6]66void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
67        dst->virtual_table = src->virtual_table;
68        dst->the_thread = src->the_thread;
69        dst->the_exception = src->the_exception;
70}
71
[fd54fef]72forall(T &)
[ab8c6a6]73const char * msg(ThreadCancelled(T) *) {
[ecfd758]74        return "ThreadCancelled(...)";
[ab8c6a6]75}
76
[fd54fef]77forall(T &)
[ab8c6a6]78static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
[ecfd758]79        // Improve this error message, can I do formatting?
[ab8c6a6]80        abort( "Unhandled thread cancellation.\n" );
81}
82
[ecfd758]83static void default_thread_cancel_handler(SomeThreadCancelled & ) {
84        // Improve this error message, can I do formatting?
85        abort( "Unhandled thread cancellation.\n" );
86}
87
88forall(T & | is_thread(T) | IS_EXCEPTION(SomeThreadCancelled))
[ab8c6a6]89void ?{}( thread_dtor_guard_t & this,
[ecfd758]90                T & thrd, void(*cancelHandler)(SomeThreadCancelled &)) {
91        $monitor * m = get_monitor(thrd);
[3ea8ad1]92        $thread * desc = get_thread(thrd);
93
94        // Setup the monitor guard
[ab8c6a6]95        void (*dtor)(T& mutex this) = ^?{};
[ecfd758]96        bool join = cancelHandler != (void(*)(SomeThreadCancelled&))0;
[ab8c6a6]97        (this.mg){&m, (void(*)())dtor, join};
[342be43]98
[3ea8ad1]99
100        /* paranoid */ verifyf( Halted == desc->state || Cancelled == desc->state, "Expected thread to be Halted or Cancelled, was %d\n", (int)desc->state );
101
[342be43]102        // After the guard set-up and any wait, check for cancellation.
103        struct _Unwind_Exception * cancellation = desc->self_cor.cancellation;
104        if ( likely( 0p == cancellation ) ) {
105                return;
106        } else if ( Cancelled == desc->state ) {
107                return;
108        }
109        desc->state = Cancelled;
[ecfd758]110        void(*defaultResumptionHandler)(SomeThreadCancelled &) =
[fcd0b9d7]111                join ? cancelHandler : default_thread_cancel_handler;
[342be43]112
113        // TODO: Remove explitate vtable set once trac#186 is fixed.
[ecfd758]114        SomeThreadCancelled except;
115        except.virtual_table = &std_thread_cancelled;
[342be43]116        except.the_thread = &thrd;
117        except.the_exception = __cfaehm_cancellation_exception( cancellation );
[ecfd758]118        // Why is this cast required?
119        throwResume (SomeThreadCancelled &)except;
[342be43]120
121        except.the_exception->virtual_table->free( except.the_exception );
122        free( cancellation );
123        desc->self_cor.cancellation = 0p;
[ab8c6a6]124}
125
126void ^?{}( thread_dtor_guard_t & this ) {
127        ^(this.mg){};
128}
129
[8118303]130//-----------------------------------------------------------------------------
131// Starting and stopping threads
[fd54fef]132forall( T & | is_thread(T) )
[09f357e]133void __thrd_start( T & this, void (*main_p)(T &) ) {
[ac2b598]134        $thread * this_thrd = get_thread(this);
[8118303]135
[1c273d0]136        disable_interrupts();
[c7a900a]137        __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
[09f357e]138
[e8e457e]139        this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
[ac5816d]140        /* paranoid */ verify( this_thrd->context.SP );
[8118303]141
[e873838]142        __schedule_thread( this_thrd );
[36982fc]143        enable_interrupts( __cfaabi_dbg_ctx );
[8118303]144}
145
[8c50aed]146//-----------------------------------------------------------------------------
147// Support for threads that don't ues the thread keyword
[fd54fef]148forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
[65deb18]149void ?{}( scoped(T)& this ) with( this ) {
150        handle{};
[09f357e]151        __thrd_start(handle, main);
[bd98b58]152}
153
[fd54fef]154forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
[65deb18]155void ?{}( scoped(T)& this, P params ) with( this ) {
156        handle{ params };
[09f357e]157        __thrd_start(handle, main);
[8118303]158}
159
[fd54fef]160forall( T & | sized(T) | is_thread(T) )
[65deb18]161void ^?{}( scoped(T)& this ) with( this ) {
162        ^handle{};
[44264c5]163}
164
[ab8c6a6]165//-----------------------------------------------------------------------------
[ecfd758]166forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(SomeThreadCancelled))
[ab8c6a6]167T & join( T & this ) {
168        thread_dtor_guard_t guard = { this, defaultResumptionHandler };
169        return this;
170}
171
[fe9468e2]172uint64_t thread_rand() {
173        disable_interrupts();
174        uint64_t ret = __tls_rand();
175        enable_interrupts( __cfaabi_dbg_ctx );
176        return ret;
177}
178
[78b3f52]179// Local Variables: //
180// mode: c //
181// tab-width: 4 //
[6a3d2e7]182// End: //
Note: See TracBrowser for help on using the repository browser.