From 6c56dae4b23c5c50e351758538141ca26b9aba40 Mon Sep 17 00:00:00 2001 From: kosaki Date: Mon, 19 Nov 2012 10:22:53 +0000 Subject: * prelude.rb: Moved Mutex#synchronize to * thread.c (rb_mutex_synchronize_m): here. [Bug #4266] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@37724 b2dd03c8-39d4-4d8f-98ff-823fe69b080e --- thread.c | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) (limited to 'thread.c') diff --git a/thread.c b/thread.c index 4a3aeaa396..bf5cb9be61 100644 --- a/thread.c +++ b/thread.c @@ -4285,6 +4285,23 @@ rb_mutex_synchronize(VALUE mutex, VALUE (*func)(VALUE arg), VALUE arg) return rb_ensure(func, arg, rb_mutex_unlock, mutex); } +/* + * call-seq: + * mutex.synchronize { ... } -> result of the block + * + * Obtains a lock, runs the block, and releases the lock when the block + * completes. See the example under +Mutex+. + */ +static VALUE +rb_mutex_synchronize_m(VALUE self, VALUE args) +{ + if (!rb_block_given_p()) { + rb_raise(rb_eThreadError, "must be called with a block"); + } + + return rb_mutex_synchronize(self, rb_yield, Qnil); +} + /* * Document-class: ThreadShield */ @@ -4740,6 +4757,7 @@ Init_Thread(void) rb_define_method(rb_cMutex, "lock", rb_mutex_lock, 0); rb_define_method(rb_cMutex, "unlock", rb_mutex_unlock, 0); rb_define_method(rb_cMutex, "sleep", mutex_sleep, -1); + rb_define_method(rb_cMutex, "synchronize", rb_mutex_synchronize_m, 0); recursive_key = rb_intern("__recursive_key__"); rb_eThreadError = rb_define_class("ThreadError", rb_eStandardError); -- cgit v1.2.3