source: src/libcfa/concurrency/monitor @ cb0e6de

aaron-thesisarm-ehcleanup-dtorsdeferred_resndemanglerjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerresolv-newwith_gc
Last change on this file since cb0e6de was cb0e6de, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

Threads now use monitor semantics to wait until completion

  • Property mode set to 100644
File size: 1.2 KB
Line 
1//                              -*- Mode: CFA -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// monitor --
9//
10// Author           : Thierry Delisle
11// Created On       : Thd Feb 23 12:27:26 2017
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count     : 0
15//
16
17#ifndef MONITOR_H
18#define MONITOR_H
19
20#include "assert"
21#include "invoke.h"
22#include "stdlib"
23
24static inline void ?{}(monitor_desc * this) {
25        this->owner = 0;
26        this->recursion = 0;
27}
28
29//Array entering routine
30void enter(monitor_desc **, int count);
31void leave(monitor_desc **, int count);
32
33struct monitor_guard_t {
34        monitor_desc ** m;
35        int count;
36};
37
38static inline int ?<?(monitor_desc* lhs, monitor_desc* rhs) {
39        return ((intptr_t)lhs) < ((intptr_t)rhs);
40}
41
42static inline void ?{}( monitor_guard_t * this, monitor_desc ** m, int count ) {
43        this->m = m;
44        this->count = count;
45        qsort(this->m, count);
46        enter( this->m, this->count );
47}
48
49static inline void ^?{}( monitor_guard_t * this ) {
50        leave( this->m, this->count );
51}
52
53
54#endif //MONITOR_H
Note: See TracBrowser for help on using the repository browser.