1berry/ruby
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[DOC] Monitor

Browse Source
This commit is contained in:
Nobuyoshi Nakada 2024-12-25 10:30:40 +09:00
parent c194357c08
commit e46314edd1
No known key found for this signature in database
GPG Key ID: 3582D74E1FEE4465
Notes: git 2024-12-25 01:38:35 +00:00 
Merged: https://github.com/ruby/ruby/pull/12460
2 changed files with 36 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ext/monitor/lib/monitor.rb
View File

@ -143,13 +143,13 @@ module MonitorMixin
private
def initialize(monitor)
def initialize(monitor) # :nodoc:
@monitor = monitor
@cond = Thread::ConditionVariable.new
end
end
def self.extend_object(obj)
def self.extend_object(obj) # :nodoc:
super(obj)
obj.__send__(:mon_initialize)
end
@ -254,6 +254,10 @@ end
# end
#
class Monitor
#
# Creates a new MonitorMixin::ConditionVariable associated with the
# Monitor object.
#
def new_cond
::MonitorMixin::ConditionVariable.new(self)
end

30
ext/monitor/monitor.c
View File

@ -56,6 +56,12 @@ mc_owner_p(struct rb_monitor *mc)
return mc->owner == rb_fiber_current();
}
/*
* call-seq:
* try_enter -> true or false
*
* Attempts to enter exclusive section. Returns +false+ if lock fails.
*/
static VALUE
monitor_try_enter(VALUE monitor)
{
@ -72,6 +78,12 @@ monitor_try_enter(VALUE monitor)
return Qtrue;
}
/*
* call-seq:
* enter -> nil
*
* Enters exclusive section.
*/
static VALUE
monitor_enter(VALUE monitor)
{
@ -85,6 +97,7 @@ monitor_enter(VALUE monitor)
return Qnil;
}
/* :nodoc: */
static VALUE
monitor_check_owner(VALUE monitor)
{
@ -95,6 +108,12 @@ monitor_check_owner(VALUE monitor)
return Qnil;
}
/*
* call-seq:
* exit -> nil
*
* Leaves exclusive section.
*/
static VALUE
monitor_exit(VALUE monitor)
{
@ -112,6 +131,7 @@ monitor_exit(VALUE monitor)
return Qnil;
}
/* :nodoc: */
static VALUE
monitor_locked_p(VALUE monitor)
{
@ -119,6 +139,7 @@ monitor_locked_p(VALUE monitor)
return rb_mutex_locked_p(mc->mutex);
}
/* :nodoc: */
static VALUE
monitor_owned_p(VALUE monitor)
{
@ -166,6 +187,7 @@ monitor_enter_for_cond(VALUE v)
return Qnil;
}
/* :nodoc: */
static VALUE
monitor_wait_for_cond(VALUE monitor, VALUE cond, VALUE timeout)
{
@ -193,6 +215,14 @@ monitor_sync_ensure(VALUE monitor)
return monitor_exit(monitor);
}
/*
* call-seq:
* synchronize { } -> result of the block
*
* Enters exclusive section and executes the block. Leaves the exclusive
* section automatically when the block exits. See example under
* +MonitorMixin+.
*/
static VALUE
monitor_synchronize(VALUE monitor)
{