source: libcfa/src/concurrency/thread.hfa @ 74e3263

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since 74e3263 was 09f357ec, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

Optim : coroutine and thread creation no-longer uses polymorphic call, leading to significant speedup. Breaks Arm support

  • Property mode set to 100644
File size: 3.7 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 --
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:18:14 2019
13// Update Count     : 6
14//
15
16#pragma once
17
18#include <assert.h>
19#include "invoke.h"
20
21#include "coroutine.hfa"
22#include "kernel.hfa"
23#include "monitor.hfa"
24
25//-----------------------------------------------------------------------------
26// thread trait
27trait is_thread(dtype T) {
28      void ^?{}(T& mutex this);
29      void main(T& this);
30      thread_desc* get_thread(T& this);
31};
32
33#define DECL_THREAD(X) thread_desc* get_thread(X& this) { return &this.__thrd; } void main(X& this)
34
35forall( dtype T | is_thread(T) )
36static inline coroutine_desc* get_coroutine(T & this) {
37        return &get_thread(this)->self_cor;
38}
39
40forall( dtype T | is_thread(T) )
41static inline monitor_desc* get_monitor(T & this) {
42        return &get_thread(this)->self_mon;
43}
44
45static inline coroutine_desc* get_coroutine(thread_desc * this) {
46        return &this->self_cor;
47}
48
49static inline monitor_desc* get_monitor(thread_desc * this) {
50        return &this->self_mon;
51}
52
53extern struct cluster * mainCluster;
54
55forall( dtype T | is_thread(T) )
56void __thrd_start( T & this, void (*)(T &) );
57
58//-----------------------------------------------------------------------------
59// Ctors and dtors
60void ?{}(thread_desc & this, const char * const name, struct cluster & cl, void * storage, size_t storageSize );
61void ^?{}(thread_desc & this);
62
63static inline void ?{}(thread_desc & this)                                                                  { this{ "Anonymous Thread", *mainCluster, 0p, 65000 }; }
64static inline void ?{}(thread_desc & this, size_t stackSize )                                               { this{ "Anonymous Thread", *mainCluster, 0p, stackSize }; }
65static inline void ?{}(thread_desc & this, void * storage, size_t storageSize )                             { this{ "Anonymous Thread", *mainCluster, storage, storageSize }; }
66static inline void ?{}(thread_desc & this, struct cluster & cl )                                            { this{ "Anonymous Thread", cl, 0p, 65000 }; }
67static inline void ?{}(thread_desc & this, struct cluster & cl, size_t stackSize )                          { this{ "Anonymous Thread", cl, 0p, stackSize }; }
68static inline void ?{}(thread_desc & this, struct cluster & cl, void * storage, size_t storageSize )        { this{ "Anonymous Thread", cl, storage, storageSize }; }
69static inline void ?{}(thread_desc & this, const char * const name)                                         { this{ name, *mainCluster, 0p, 65000 }; }
70static inline void ?{}(thread_desc & this, const char * const name, struct cluster & cl )                   { this{ name, cl, 0p, 65000 }; }
71static inline void ?{}(thread_desc & this, const char * const name, struct cluster & cl, size_t stackSize ) { this{ name, cl, 0p, stackSize }; }
72
73//-----------------------------------------------------------------------------
74// thread runner
75// Structure that actually start and stop threads
76forall( dtype T | sized(T) | is_thread(T) )
77struct scoped {
78        T handle;
79};
80
81forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
82void ?{}( scoped(T)& this );
83
84forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
85void ?{}( scoped(T)& this, P params );
86
87forall( dtype T | sized(T) | is_thread(T) )
88void ^?{}( scoped(T)& this );
89
90void yield();
91void yield( unsigned times );
92
93static inline struct thread_desc * active_thread () { return TL_GET( this_thread ); }
94
95// Local Variables: //
96// mode: c //
97// tab-width: 4 //
98// End: //
Note: See TracBrowser for help on using the repository browser.