1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
/*
* Copyright 2019 elementary, Inc. (https://elementary.io)
* SPDX-License-Identifier: GPL-3.0-or-later
*/
namespace Granite.Services {
internal class AsyncMutex {
private class Callback {
public SourceFunc callback;
public Callback (owned SourceFunc cb) {
callback = (owned)cb;
}
}
private Gee.ArrayQueue<Callback> callbacks;
private bool locked;
public AsyncMutex () {
locked = false;
callbacks = new Gee.ArrayQueue<Callback> ();
}
public async void lock () {
while (locked) {
SourceFunc cb = lock.callback;
callbacks.offer_head (new Callback ((owned)cb));
yield;
}
locked = true;
}
public void unlock () {
locked = false;
var callback = callbacks.poll_head ();
if (callback != null) {
Idle.add ((owned)callback.callback);
}
}
}
}
|
