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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
package thread
import "core:runtime"
import "core:sync"
import "core:intrinsics"
Thread_Proc :: #type proc(^Thread);
Thread :: struct {
using specific: Thread_Os_Specific,
procedure: Thread_Proc,
data: rawptr,
user_index: int,
init_context: Maybe(runtime.Context),
}
#assert(size_of(Thread{}.user_index) == size_of(uintptr));
run :: proc(fn: proc(), init_context: Maybe(runtime.Context) = nil, priority := Thread_Priority.Normal) {
thread_proc :: proc(t: ^Thread) {
fn := cast(proc())t.data;
fn();
destroy(t);
}
t := create(thread_proc, priority);
t.data = rawptr(fn);
t.init_context = init_context;
start(t);
}
run_with_data :: proc(data: rawptr, fn: proc(data: rawptr), init_context: Maybe(runtime.Context) = nil, priority := Thread_Priority.Normal) {
thread_proc :: proc(t: ^Thread) {
fn := cast(proc(rawptr))t.data;
data := rawptr(uintptr(t.user_index));
fn(data);
destroy(t);
}
t := create(thread_proc, priority);
t.data = rawptr(fn);
t.user_index = int(uintptr(data));
t.init_context = init_context;
start(t);
}
create_and_start :: proc(fn: Thread_Proc, init_context: Maybe(runtime.Context) = nil, priority := Thread_Priority.Normal) -> ^Thread {
t := create(fn, priority);
t.init_context = init_context;
start(t);
return t;
}
Once :: struct {
m: sync.Blocking_Mutex,
done: bool,
}
once_init :: proc(o: ^Once) {
sync.blocking_mutex_init(&o.m);
intrinsics.atomic_store_rel(&o.done, false);
}
once_destroy :: proc(o: ^Once) {
sync.blocking_mutex_destroy(&o.m);
}
once_do :: proc(o: ^Once, fn: proc()) {
if intrinsics.atomic_load(&o.done) == false {
_once_do_slow(o, fn);
}
}
_once_do_slow :: proc(o: ^Once, fn: proc()) {
sync.blocking_mutex_lock(&o.m);
defer sync.blocking_mutex_unlock(&o.m);
if !o.done {
fn();
intrinsics.atomic_store_rel(&o.done, true);
}
}
|
