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

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since fd54fef was fd54fef, checked in by Michael Brooks <mlbrooks@…>, 3 years ago

Converting the project to use the new syntax for otype, dtype and ttytpe.

Changed prelude (gen), libcfa and test suite to use it. Added a simple deprecation rule of the old syntax to the parser; we might wish to support both syntaxes "officially," like with an extra CLI switch, but this measure should serve as a simple reminder for our team to try the new syntax.

  • Property mode set to 100644
File size: 5.2 KB
RevLine 
[0e76cf4f]1//
[78b3f52]2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
[0e76cf4f]3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
[75a17f1]7// thread --
[0e76cf4f]8//
[78b3f52]9// Author           : Thierry Delisle
[f07e037]10// Created On       : Tue Jan 17 12:27:26 2017
[91c389a]11// Last Modified By : Peter A. Buhr
[121be3e]12// Last Modified On : Wed Dec  4 09:18:14 2019
13// Update Count     : 6
[0e76cf4f]14//
15
[6b0b624]16#pragma once
[0e76cf4f]17
[91c389a]18#include <assert.h>
[8118303]19#include "invoke.h"
[78b3f52]20
[58b6d1b]21#include "coroutine.hfa"
22#include "kernel.hfa"
23#include "monitor.hfa"
[ab8c6a6]24#include "exception.hfa"
[8118303]25
26//-----------------------------------------------------------------------------
[de6319f]27// thread trait
[fd54fef]28trait is_thread(T &) {
[ab8c6a6]29        void ^?{}(T& mutex this);
30        void main(T& this);
31        $thread* get_thread(T& this);
[8118303]32};
33
[fd54fef]34FORALL_DATA_EXCEPTION(ThreadCancelled, (thread_t &), (thread_t)) (
[ab8c6a6]35        thread_t * the_thread;
36        exception_t * the_exception;
37);
38
[fd54fef]39forall(T &)
[ab8c6a6]40void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src);
41
[fd54fef]42forall(T &)
[ab8c6a6]43const char * msg(ThreadCancelled(T) *);
44
[8c50aed]45// define that satisfies the trait without using the thread keyword
[ac2b598]46#define DECL_THREAD(X) $thread* get_thread(X& this) __attribute__((const)) { return &this.__thrd; } void main(X& this)
[8f49a54]47
[8c50aed]48// Inline getters for threads/coroutines/monitors
[fd54fef]49forall( T & | is_thread(T) )
[ac2b598]50static inline $coroutine* get_coroutine(T & this) __attribute__((const)) { return &get_thread(this)->self_cor; }
[8118303]51
[fd54fef]52forall( T & | is_thread(T) )
[ac2b598]53static inline $monitor  * get_monitor  (T & this) __attribute__((const)) { return &get_thread(this)->self_mon; }
[cb0e6de]54
[ac2b598]55static inline $coroutine* get_coroutine($thread * this) __attribute__((const)) { return &this->self_cor; }
56static inline $monitor  * get_monitor  ($thread * this) __attribute__((const)) { return &this->self_mon; }
[cb0e6de]57
[8c50aed]58//-----------------------------------------------------------------------------
59// forward declarations needed for threads
[de6319f]60extern struct cluster * mainCluster;
[bd98b58]61
[fd54fef]62forall( T & | is_thread(T) )
[09f357ec]63void __thrd_start( T & this, void (*)(T &) );
[bd4d011]64
[8118303]65//-----------------------------------------------------------------------------
66// Ctors and dtors
[ac2b598]67void ?{}($thread & this, const char * const name, struct cluster & cl, void * storage, size_t storageSize );
68void ^?{}($thread & this);
69
70static inline void ?{}($thread & this)                                                                  { this{ "Anonymous Thread", *mainCluster, 0p, 65000 }; }
71static inline void ?{}($thread & this, size_t stackSize )                                               { this{ "Anonymous Thread", *mainCluster, 0p, stackSize }; }
72static inline void ?{}($thread & this, void * storage, size_t storageSize )                             { this{ "Anonymous Thread", *mainCluster, storage, storageSize }; }
73static inline void ?{}($thread & this, struct cluster & cl )                                            { this{ "Anonymous Thread", cl, 0p, 65000 }; }
74static inline void ?{}($thread & this, struct cluster & cl, size_t stackSize )                          { this{ "Anonymous Thread", cl, 0p, stackSize }; }
75static inline void ?{}($thread & this, struct cluster & cl, void * storage, size_t storageSize )        { this{ "Anonymous Thread", cl, storage, storageSize }; }
76static inline void ?{}($thread & this, const char * const name)                                         { this{ name, *mainCluster, 0p, 65000 }; }
77static inline void ?{}($thread & this, const char * const name, struct cluster & cl )                   { this{ name, cl, 0p, 65000 }; }
78static inline void ?{}($thread & this, const char * const name, struct cluster & cl, size_t stackSize ) { this{ name, cl, 0p, stackSize }; }
[8118303]79
[ab8c6a6]80struct thread_dtor_guard_t {
81        monitor_dtor_guard_t mg;
82};
83
[fd54fef]84forall( T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T)) )
[ab8c6a6]85void ?{}( thread_dtor_guard_t & this, T & thrd, void(*)(ThreadCancelled(T) &) );
86void ^?{}( thread_dtor_guard_t & this );
87
[8118303]88//-----------------------------------------------------------------------------
89// thread runner
90// Structure that actually start and stop threads
[fd54fef]91forall( T & | sized(T) | is_thread(T) )
[e15df4c]92struct scoped {
[8118303]93        T handle;
94};
95
[fd54fef]96forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
[242a902]97void ?{}( scoped(T)& this );
[8118303]98
[fd54fef]99forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
[242a902]100void ?{}( scoped(T)& this, P params );
[8118303]101
[fd54fef]102forall( T & | sized(T) | is_thread(T) )
[242a902]103void ^?{}( scoped(T)& this );
[8118303]104
[3381ed7]105//-----------------------------------------------------------------------------
106// Scheduler API
107
108//----------
109// Park thread: block until corresponding call to unpark, won't block if unpark is already called
[e235429]110void park( void );
[3381ed7]111
112//----------
113// Unpark a thread, if the thread is already blocked, schedule it
[b0c7419]114//                  if the thread is not yet block, signal that it should rerun immediately
[e235429]115void unpark( $thread * this );
[3381ed7]116
[fd54fef]117forall( T & | is_thread(T) )
[e235429]118static inline void unpark( T & this ) { if(!&this) return; unpark( get_thread( this ) );}
[3381ed7]119
120//----------
121// Yield: force thread to block and be rescheduled
[b0c7419]122bool force_yield( enum __Preemption_Reason );
123
[2d8f7b0]124//----------
125// sleep: force thread to block and be rescheduled after Duration duration
126void sleep( Duration duration );
127
[77a2994]128//----------
129// join
[fd54fef]130forall( T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T)) )
[77a2994]131T & join( T & this );
132
[78b3f52]133// Local Variables: //
134// mode: c //
135// tab-width: 4 //
136// End: //
Note: See TracBrowser for help on using the repository browser.