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
|
#include "futex.h"
#ifdef _linux_
#include <linux/futex.h>
#include <sys/time.h>
#include <sys/syscall.h>
#endif
namespace NYT::NThreading {
////////////////////////////////////////////////////////////////////////////////
#ifdef _linux_
namespace {
int Futex(
int* uaddr,
int op,
int val,
const timespec* timeout,
int* uaddr2,
int val3)
{
return ::syscall(SYS_futex, uaddr, op, val, timeout, uaddr2, val3);
}
} // namespace
int FutexWait(int* addr, int value, TDuration timeout)
{
struct timespec timeoutSpec;
if (timeout != TDuration::Max()) {
timeoutSpec.tv_sec = timeout.Seconds();
timeoutSpec.tv_nsec = (timeout - TDuration::Seconds(timeout.Seconds())).MicroSeconds() * 1000;
}
return Futex(
addr,
FUTEX_WAIT_PRIVATE,
value,
timeout != TDuration::Max() ? &timeoutSpec : nullptr,
nullptr,
0);
}
int FutexWake(int* addr, int count)
{
return Futex(
addr,
FUTEX_WAKE_PRIVATE,
count,
nullptr,
nullptr,
0);
}
#endif
////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NThreading
|
