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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
use std::convert::From;
use crate::{binding::thread, types::Value};
#[cfg(unix)]
use crate::types::RawFd;
use crate::{AnyObject, Class, Object, VerifiedObject};
/// `Thread`
#[derive(Debug)]
#[repr(C)]
pub struct Thread {
value: Value,
}
impl Thread {
/// Creates a new green thread.
///
/// The returning value of the closure will be available as `#value` of the thread
///
/// # Examples
///
/// ```
/// use rutie::{Fixnum, Thread, VM};
/// # VM::init();
///
/// Thread::new(|| {
/// let computation_result = 1 + 2;
///
/// Fixnum::new(computation_result)
/// });
/// ```
///
/// Ruby:
///
/// ```ruby
/// Thread.new do
/// computation_result = 1 + 2
///
/// computation_result
/// end
/// ```
pub fn new<F, R>(func: F) -> Self
where
F: FnMut() -> R,
R: Object,
{
Self::from(thread::create(func))
}
/// Tells scheduler to switch to other threads while current thread is waiting for a
/// readable event on the given file descriptor.
///
/// # Examples
///
/// ```
/// use std::os::unix::io::AsRawFd;
/// use std::os::unix::net::UnixStream;
///
/// use rutie::{Thread, VM};
/// # VM::init();
///
/// let (unix_socket, _) = UnixStream::pair().unwrap();
///
/// Thread::wait_fd(unix_socket.as_raw_fd());
/// ```
#[cfg(unix)]
pub fn wait_fd(fd: RawFd) {
thread::wait_fd(fd);
}
/// Release GVL for current thread.
///
/// **Warning!** Due to MRI limitations, interaction with Ruby objects is not allowed while
/// GVL is released, it may cause unexpected behaviour.
/// [Read more at Ruby documentation](https://github.com/ruby/ruby/blob/2fc5210f31ad23463d7b0a0e36bcfbeee7b41b3e/thread.c#L1314-L1398)
///
/// You should extract all the information from Ruby world before invoking
/// `thread_call_without_gvl`.
///
/// GVL will be re-acquired when the closure is finished.
///
/// # Examples
///
/// ```no_run
/// #[macro_use] extern crate rutie;
///
/// use rutie::{Class, Fixnum, Object, Thread};
///
/// class!(Calculator);
///
/// methods!(
/// Calculator,
/// rtself,
///
/// fn heavy_computation() -> Fixnum {
/// let computation = || { 2 * 2 };
/// let unblocking_function = || {};
///
/// // release GVL for current thread until `computation` is completed
/// let result = Thread::call_without_gvl(
/// computation,
/// Some(unblocking_function)
/// );
///
/// // GVL is re-acquired, we can interact with Ruby-world
/// Fixnum::new(result)
/// }
/// );
///
/// fn main() {
/// Class::new("Calculator", None).define(|klass| {
/// klass.def("heavy_computation", heavy_computation);
/// });
/// }
/// ```
pub fn call_without_gvl<F, R, G>(func: F, unblock_func: Option<G>) -> R
where
F: FnMut() -> R,
G: FnMut(),
{
thread::call_without_gvl(func, unblock_func)
}
pub fn call_without_gvl2<F, R, G>(func: F, unblock_func: Option<G>) -> R
where
F: FnMut() -> R,
G: FnMut(),
{
thread::call_without_gvl2(func, unblock_func)
}
pub fn call_with_gvl<F, R>(func: F) -> R
where
F: FnMut() -> R,
{
thread::call_with_gvl(func)
}
}
impl From<Value> for Thread {
fn from(value: Value) -> Self {
Thread { value }
}
}
impl Into<Value> for Thread {
fn into(self) -> Value {
self.value
}
}
impl Into<AnyObject> for Thread {
fn into(self) -> AnyObject {
AnyObject::from(self.value)
}
}
impl Object for Thread {
#[inline]
fn value(&self) -> Value {
self.value
}
}
impl VerifiedObject for Thread {
fn is_correct_type<T: Object>(object: &T) -> bool {
object.class() == Class::from_existing("Thread")
}
fn error_message() -> &'static str {
"Error converting to Thread"
}
}
impl PartialEq for Thread {
fn eq(&self, other: &Self) -> bool {
self.equals(other)
}
}