source: src/libcfa/concurrency/thread @ 43725bd

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

Refactoring monitor code in prevision for proper waitfor support

  • added monitor group struct
  • else and timeout now return negative results
  • Property mode set to 100644
File size: 2.2 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 : Sat Jul 22 09:59:40 2017
13// Update Count     : 3
14//
15
16#pragma once
17
18#include <assert.h>
19#include "invoke.h"
20
21#include "coroutine"
22#include "monitor"
23
24//-----------------------------------------------------------------------------
25// Coroutine trait
26// Anything that implements this trait can be resumed.
27// Anything that is resumed is a coroutine.
28trait is_thread(dtype T) {
29      void ^?{}(T& mutex this);
30      void main(T& this);
31      thread_desc* get_thread(T& this);
32};
33
34#define DECL_THREAD(X) thread_desc* get_thread(X& this) { return &this.__thrd; } void main(X& this)
35
36forall( dtype T | is_thread(T) )
37static inline coroutine_desc* get_coroutine(T & this) {
38        return &get_thread(this)->self_cor;
39}
40
41forall( dtype T | is_thread(T) )
42static inline monitor_desc* get_monitor(T & this) {
43        return &get_thread(this)->self_mon;
44}
45
46static inline coroutine_desc* get_coroutine(thread_desc * this) {
47        return &this->self_cor;
48}
49
50static inline monitor_desc* get_monitor(thread_desc * this) {
51        return &this->self_mon;
52}
53
54extern thread_local thread_desc * volatile this_thread;
55
56forall( dtype T | is_thread(T) )
57void __thrd_start( T & this );
58
59//-----------------------------------------------------------------------------
60// Ctors and dtors
61void ?{}(thread_desc& this);
62void ^?{}(thread_desc& this);
63
64//-----------------------------------------------------------------------------
65// thread runner
66// Structure that actually start and stop threads
67forall( dtype T | sized(T) | is_thread(T) )
68struct scoped {
69        T handle;
70};
71
72forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
73void ?{}( scoped(T)& this );
74
75forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
76void ?{}( scoped(T)& this, P params );
77
78forall( dtype T | sized(T) | is_thread(T) )
79void ^?{}( scoped(T)& this );
80
81void yield();
82void yield( unsigned times );
83
84// Local Variables: //
85// mode: c //
86// tab-width: 4 //
87// End: //
Note: See TracBrowser for help on using the repository browser.