source: libcfa/src/concurrency/thread.hfa @ e235429

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

Removed last parker/unparker information is it was not particularly useful

  • Property mode set to 100644
File size: 4.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* get_thread(T& this);
31};
32
33// define that satisfies the trait without using the thread keyword
34#define DECL_THREAD(X) $thread* get_thread(X& this) __attribute__((const)) { return &this.__thrd; } void main(X& this)
35
36// Inline getters for threads/coroutines/monitors
37forall( dtype T | is_thread(T) )
38static inline $coroutine* get_coroutine(T & this) __attribute__((const)) { return &get_thread(this)->self_cor; }
39
40forall( dtype T | is_thread(T) )
41static inline $monitor  * get_monitor  (T & this) __attribute__((const)) { return &get_thread(this)->self_mon; }
42
43static inline $coroutine* get_coroutine($thread * this) __attribute__((const)) { return &this->self_cor; }
44static inline $monitor  * get_monitor  ($thread * this) __attribute__((const)) { return &this->self_mon; }
45
46//-----------------------------------------------------------------------------
47// forward declarations needed for threads
48extern struct cluster * mainCluster;
49
50forall( dtype T | is_thread(T) )
51void __thrd_start( T & this, void (*)(T &) );
52
53//-----------------------------------------------------------------------------
54// Ctors and dtors
55void ?{}($thread & this, const char * const name, struct cluster & cl, void * storage, size_t storageSize );
56void ^?{}($thread & this);
57
58static inline void ?{}($thread & this)                                                                  { this{ "Anonymous Thread", *mainCluster, 0p, 65000 }; }
59static inline void ?{}($thread & this, size_t stackSize )                                               { this{ "Anonymous Thread", *mainCluster, 0p, stackSize }; }
60static inline void ?{}($thread & this, void * storage, size_t storageSize )                             { this{ "Anonymous Thread", *mainCluster, storage, storageSize }; }
61static inline void ?{}($thread & this, struct cluster & cl )                                            { this{ "Anonymous Thread", cl, 0p, 65000 }; }
62static inline void ?{}($thread & this, struct cluster & cl, size_t stackSize )                          { this{ "Anonymous Thread", cl, 0p, stackSize }; }
63static inline void ?{}($thread & this, struct cluster & cl, void * storage, size_t storageSize )        { this{ "Anonymous Thread", cl, storage, storageSize }; }
64static inline void ?{}($thread & this, const char * const name)                                         { this{ name, *mainCluster, 0p, 65000 }; }
65static inline void ?{}($thread & this, const char * const name, struct cluster & cl )                   { this{ name, cl, 0p, 65000 }; }
66static inline void ?{}($thread & this, const char * const name, struct cluster & cl, size_t stackSize ) { this{ name, cl, 0p, stackSize }; }
67
68//-----------------------------------------------------------------------------
69// thread runner
70// Structure that actually start and stop threads
71forall( dtype T | sized(T) | is_thread(T) )
72struct scoped {
73        T handle;
74};
75
76forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
77void ?{}( scoped(T)& this );
78
79forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
80void ?{}( scoped(T)& this, P params );
81
82forall( dtype T | sized(T) | is_thread(T) )
83void ^?{}( scoped(T)& this );
84
85//-----------------------------------------------------------------------------
86// Scheduler API
87
88//----------
89// Park thread: block until corresponding call to unpark, won't block if unpark is already called
90void park( void );
91
92//----------
93// Unpark a thread, if the thread is already blocked, schedule it
94//                  if the thread is not yet block, signal that it should rerun immediately
95void unpark( $thread * this );
96
97forall( dtype T | is_thread(T) )
98static inline void unpark( T & this ) { if(!&this) return; unpark( get_thread( this ) );}
99
100//----------
101// Yield: force thread to block and be rescheduled
102bool force_yield( enum __Preemption_Reason );
103
104//----------
105// sleep: force thread to block and be rescheduled after Duration duration
106void sleep( Duration duration );
107
108//----------
109// join
110forall( dtype T | is_thread(T) )
111T & join( T & this );
112
113// Local Variables: //
114// mode: c //
115// tab-width: 4 //
116// End: //
Note: See TracBrowser for help on using the repository browser.