pub struct Thread { /* private fields */ }
Expand description
Thread
Implementations
sourceimpl Thread
impl Thread
sourcepub fn new<F, R>(func: F) -> Selfwhere
F: 'static + FnOnce() -> R,
R: Object,
pub fn new<F, R>(func: F) -> Selfwhere
F: 'static + FnOnce() -> R,
R: Object,
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};
Thread::new(|| {
let computation_result = 1 + 2;
Fixnum::new(computation_result)
});
Ruby:
Thread.new do
computation_result = 1 + 2
computation_result
end
sourcepub fn wait_fd(fd: RawFd)
pub fn wait_fd(fd: RawFd)
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};
let (unix_socket, _) = UnixStream::pair().unwrap();
Thread::wait_fd(unix_socket.as_raw_fd());
sourcepub fn call_without_gvl<F, R, G>(func: F, unblock_func: Option<G>) -> Rwhere
F: 'static + FnOnce() -> R,
G: 'static + FnOnce(),
pub fn call_without_gvl<F, R, G>(func: F, unblock_func: Option<G>) -> Rwhere
F: 'static + FnOnce() -> R,
G: 'static + FnOnce(),
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
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
#[macro_use] extern crate rutie;
use rutie::{Class, Fixnum, Object, Thread};
class!(Calculator);
methods!(
Calculator,
itself,
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(|itself| {
itself.def("heavy_computation", heavy_computation);
});
}
pub fn call_without_gvl2<F, R, G>(func: F, unblock_func: Option<G>) -> Rwhere
F: 'static + FnOnce() -> R,
G: 'static + FnOnce(),
pub fn call_with_gvl<F, R>(func: F) -> Rwhere
F: 'static + FnOnce() -> R,
Trait Implementations
sourceimpl Object for Thread
impl Object for Thread
sourcefn singleton_class(&self) -> Class
fn singleton_class(&self) -> Class
Returns a singleton class of current object. Read more
sourcefn get_data<'a, T>(&'a self, wrapper: &'a dyn DataTypeWrapper<T>) -> &'_ T
fn get_data<'a, T>(&'a self, wrapper: &'a dyn DataTypeWrapper<T>) -> &'_ T
Gets an immutable reference to the Rust structure which is wrapped into a Ruby object. Read more
sourcefn get_data_mut<'a, T>(
&'a mut self,
wrapper: &'a dyn DataTypeWrapper<T>
) -> &'_ mut T
fn get_data_mut<'a, T>(
&'a mut self,
wrapper: &'a dyn DataTypeWrapper<T>
) -> &'_ mut T
Gets a mutable reference to the Rust structure which is wrapped into a Ruby object.
sourcefn define_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
fn define_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
Defines an instance method for the given class or object. Read more
sourcefn define_private_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
fn define_private_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
Defines a private instance method for the given class or object. Read more
sourcefn define_singleton_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
fn define_singleton_method<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
Defines a class method for given class or singleton method for object. Read more
sourcefn def<I: Object, O: Object>(&mut self, name: &str, callback: Callback<I, O>)
fn def<I: Object, O: Object>(&mut self, name: &str, callback: Callback<I, O>)
An alias for
define_method
(similar to Ruby syntax def some_method
).sourcefn def_private<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
fn def_private<I: Object, O: Object>(
&mut self,
name: &str,
callback: Callback<I, O>
)
An alias for
define_private_method
(similar to Ruby syntax private def some_method
).sourcefn def_self<I: Object, O: Object>(&mut self, name: &str, callback: Callback<I, O>)
fn def_self<I: Object, O: Object>(&mut self, name: &str, callback: Callback<I, O>)
An alias for
define_singleton_method
(similar to Ruby def self.some_method
).sourcefn send(&self, method: &str, arguments: Option<&[AnyObject]>) -> AnyObject
fn send(&self, method: &str, arguments: Option<&[AnyObject]>) -> AnyObject
Calls a given method on an object similarly to Ruby
Object#send
method Read moresourcefn respond_to(&self, method: &str) -> bool
fn respond_to(&self, method: &str) -> bool
Checks whether the object responds to given method Read more
sourcefn protect_send(
&self,
method: &str,
arguments: Option<&[AnyObject]>
) -> Result<AnyObject, AnyException>
fn protect_send(
&self,
method: &str,
arguments: Option<&[AnyObject]>
) -> Result<AnyObject, AnyException>
protect_send
returns Result<AnyObject, AnyObject> Read moresourcefn protect_public_send(
&self,
method: &str,
arguments: Option<&[AnyObject]>
) -> Result<AnyObject, AnyException>
fn protect_public_send(
&self,
method: &str,
arguments: Option<&[AnyObject]>
) -> Result<AnyObject, AnyException>
protect_public_send
returns Result<AnyObject, AnyObject> Read moresourcefn to_any_object(&self) -> AnyObject
fn to_any_object(&self) -> AnyObject
Converts struct to
AnyObject
Read moresourcefn instance_variable_get(&self, variable: &str) -> AnyObject
fn instance_variable_get(&self, variable: &str) -> AnyObject
Gets an instance variable of object Read more
sourcefn instance_variable_set<T: Object>(
&mut self,
variable: &str,
value: T
) -> AnyObject
fn instance_variable_set<T: Object>(
&mut self,
variable: &str,
value: T
) -> AnyObject
Sets an instance variable for object Read more
sourceunsafe fn to<T: Object>(&self) -> T
unsafe fn to<T: Object>(&self) -> T
Unsafely casts current object to the specified Ruby type Read more
sourcefn try_convert_to<T: VerifiedObject>(&self) -> Result<T, AnyException>
fn try_convert_to<T: VerifiedObject>(&self) -> Result<T, AnyException>
Safely casts current object to the specified Ruby type Read more
sourceimpl VerifiedObject for Thread
impl VerifiedObject for Thread
fn is_correct_type<T: Object>(object: &T) -> bool
fn error_message() -> &'static str
Auto Trait Implementations
impl RefUnwindSafe for Thread
impl Send for Thread
impl Sync for Thread
impl Unpin for Thread
impl UnwindSafe for Thread
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more