source: src/libcfa/concurrency/monitor @ 2781e65

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 2781e65 was 2781e65, checked in by Thierry Delisle <tdelisle@…>, 8 years ago

added support for acquiring multiple monitors at once

  • Property mode set to 100644
File size: 1.5 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
24struct __monitor_t {
25        spinlock lock;
26        thread * owner;
27        simple_thread_list entry_queue;
28        unsigned int recursion;
29};
30
31static inline void ?{}(__monitor_t * this) {
32        this->owner = 0;
33        this->recursion = 0;
34}
35
36//Basic entering routine
37void enter(__monitor_t *);
38void leave(__monitor_t *);
39
40//Array entering routine
41void enter(__monitor_t **, int count);
42void leave(__monitor_t **, int count);
43
44struct monitor_guard_t {
45        __monitor_t ** m;
46        int count;
47};
48
49static inline int ?<?(__monitor_t* lhs, __monitor_t* rhs) {
50        return ((intptr_t)lhs) < ((intptr_t)rhs);
51}
52
53static inline void ?{}( monitor_guard_t * this, __monitor_t ** m ) {
54        this->m = m;
55        this->count = 1;
56        enter( *this->m );
57}
58
59static inline void ?{}( monitor_guard_t * this, __monitor_t ** m, int count ) {
60        this->m = m;
61        this->count = count;
62        qsort(this->m, count);
63        enter( this->m, this->count );
64}
65
66static inline void ^?{}( monitor_guard_t * this ) {
67        leave( this->m, this->count );
68}
69
70
71#endif //MONITOR_H
Note: See TracBrowser for help on using the repository browser.