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

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

Added option to bias threads to queues, instead of processors to queues

  • Property mode set to 100644
File size: 2.4 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
22#define __CFA_INVOKE_PRIVATE__
23#include "invoke.h"
24
25//-----------------------------------------------------------------------------
26// Thread ctors and dtors
27void ?{}($thread & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
28        context{ 0p, 0p };
29        self_cor{ name, storage, storageSize };
30        ticket = 1;
31        state = Start;
32        preempted = __NO_PREEMPTION;
33        curr_cor = &self_cor;
34        self_mon.owner = &this;
35        self_mon.recursion = 1;
36        self_mon_p = &self_mon;
37        curr_cluster = &cl;
38        link.next = 0p;
39        link.prev = 0p;
40        link.preferred = -1;
41
42        node.next = 0p;
43        node.prev = 0p;
44        doregister(curr_cluster, this);
45
46        monitors{ &self_mon_p, 1, (fptr_t)0 };
47}
48
49void ^?{}($thread& this) with( this ) {
50        unregister(curr_cluster, this);
51        ^self_cor{};
52}
53
54//-----------------------------------------------------------------------------
55// Starting and stopping threads
56forall( dtype T | is_thread(T) )
57void __thrd_start( T & this, void (*main_p)(T &) ) {
58        $thread * this_thrd = get_thread(this);
59
60        disable_interrupts();
61        __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
62
63        this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
64        verify( this_thrd->context.SP );
65
66        __schedule_thread( (__processor_id_t *)kernelTLS.this_processor, this_thrd);
67        enable_interrupts( __cfaabi_dbg_ctx );
68}
69
70//-----------------------------------------------------------------------------
71// Support for threads that don't ues the thread keyword
72forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
73void ?{}( scoped(T)& this ) with( this ) {
74        handle{};
75        __thrd_start(handle, main);
76}
77
78forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
79void ?{}( scoped(T)& this, P params ) with( this ) {
80        handle{ params };
81        __thrd_start(handle, main);
82}
83
84forall( dtype T | sized(T) | is_thread(T) )
85void ^?{}( scoped(T)& this ) with( this ) {
86        ^handle{};
87}
88
89// Local Variables: //
90// mode: c //
91// tab-width: 4 //
92// End: //
Note: See TracBrowser for help on using the repository browser.