source: src/libcfa/concurrency/thread.c @ 9d944b2

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 9d944b2 was 9d944b2, checked in by Thierry Delisle <tdelisle@…>, 7 years ago

Implemented interposing for abort and exit, implemented safer debug output

  • Property mode set to 100644
File size: 2.6 KB
RevLine 
[6a3d2e7]1//                              -*- Mode: CFA -*-
[78b3f52]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//
[75a17f1]8// thread.c --
[78b3f52]9//
10// Author           : Thierry Delisle
[f07e037]11// Created On       : Tue Jan 17 12:27:26 2017
[78b3f52]12// Last Modified By : Thierry Delisle
[6a3d2e7]13// Last Modified On : --
[78b3f52]14// Update Count     : 0
15//
16
[75a17f1]17#include "thread"
[78b3f52]18
[75f3522]19#include "kernel_private.h"
[8118303]20#include "libhdr.h"
21
22#define __CFA_INVOKE_PRIVATE__
23#include "invoke.h"
24
[bd98b58]25extern "C" {
[8fcbb4c]26        #include <fenv.h>
[bd98b58]27        #include <stddef.h>
28}
29
[89a3df5]30extern thread_local processor * this_processor;
[8118303]31
32//-----------------------------------------------------------------------------
33// Thread ctors and dtors
34
[348006f]35void ?{}(thread_desc* this) {
[17af7d1]36        (&this->cor){};
37        this->cor.name = "Anonymous Coroutine";
[cb0e6de]38        this->mon.owner = this;
39        this->mon.recursion = 1;
[bd98b58]40        this->next = NULL;
[8118303]41}
42
[348006f]43void ^?{}(thread_desc* this) {
[17af7d1]44        ^(&this->cor){};
[8118303]45}
46
[8def349]47forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T*); } )
[e15df4c]48void ?{}( scoped(T)* this ) {
[8118303]49        (&this->handle){};
[bd4d011]50        __thrd_start(&this->handle);
[8118303]51}
52
[8def349]53forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T*, P); } )
[e15df4c]54void ?{}( scoped(T)* this, P params ) {
[8118303]55        (&this->handle){ params };
[bd4d011]56        __thrd_start(&this->handle);
[8118303]57}
58
[9f1695b]59forall( dtype T | sized(T) | is_thread(T) )
[e15df4c]60void ^?{}( scoped(T)* this ) {
[8118303]61        ^(&this->handle){};
62}
63
64//-----------------------------------------------------------------------------
65// Starting and stopping threads
[0c92c9f]66forall( dtype T | is_thread(T) )
[bd4d011]67void __thrd_start( T* this ) {
[c3acb841]68        coroutine_desc* thrd_c = get_coroutine(this);
[348006f]69        thread_desc*  thrd_h = get_thread   (this);
[8118303]70        thrd_c->last = this_coroutine();
[89a3df5]71        this_processor->current_coroutine = thrd_c;
[8118303]72
[9d944b2]73        LIB_DEBUG_PRINT_SAFE("Thread start : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
[8118303]74
75        create_stack(&thrd_c->stack, thrd_c->stack.size);
[bd98b58]76        CtxStart(this, CtxInvokeThread);
[8118303]77        CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context );
78
[75f3522]79        ScheduleThread(thrd_h);
[8118303]80}
81
[bd98b58]82void yield( void ) {
[89a3df5]83        ScheduleInternal( this_processor->current_thread );
[bd98b58]84}
85
[c3acb841]86void ThreadCtxSwitch(coroutine_desc* src, coroutine_desc* dst) {
[0c92c9f]87        // set state of current coroutine to inactive
88        src->state = Inactive;
[75f3522]89        dst->state = Active;
[0c92c9f]90
[75f3522]91        //update the last resumer
92        dst->last = src;
[0c92c9f]93
[75f3522]94        // set new coroutine that the processor is executing
95        // and context switch to it
[89a3df5]96        this_processor->current_coroutine = dst;
[0c92c9f]97        CtxSwitch( src->stack.context, dst->stack.context );
[89a3df5]98        this_processor->current_coroutine = src;
[0c92c9f]99
100        // set state of new coroutine to active
[75f3522]101        dst->state = Inactive;
[0c92c9f]102        src->state = Active;
103}
104
[78b3f52]105// Local Variables: //
106// mode: c //
107// tab-width: 4 //
[6a3d2e7]108// End: //
Note: See TracBrowser for help on using the repository browser.