[ruby-dev:35349] Re: deadlock detection for 1.9

なかだです。

At Thu, 3 Jul 2008 01:45:54 +0900,
Yukihiro Matsumoto wrote in [ruby-dev:35331]:
> |以下が sleep forever になるのはおかしくないでしょうか。
> |
> |m = Mutex.new
> |Thread.new { m.lock; sleep 2 }
> |sleep 1; m.lock
> |
> |1.9 では下の例でも終了するようにしています。
> |これを 1.8 にあわせるのは難しそうです。
> 
> なんでsleep foreverになるんでしょうね。確かにおかしい気がし
> ます。

1.8だとスレッドがどのMutexをロックしてるかは知りませんから。
Mutex#lockで単にstopするのではなく、lockしているthreadをjoinする
ことで待つようにすれば終了するようにできます。


Index: eval.c
===================================================================
--- eval.c	(revision 17841)
+++ eval.c	(working copy)
@@ -11361,8 +11361,8 @@ rb_thread_select(max, read, write, excep
 }
 
-static int rb_thread_join _((rb_thread_t, double));
+static int rb_thread_join0 _((rb_thread_t, double));
 
 static int
-rb_thread_join(th, limit)
+rb_thread_join0(th, limit)
     rb_thread_t th;
     double limit;
@@ -11406,4 +11406,13 @@ rb_thread_join(th, limit)
 }
 
+int
+rb_thread_join(thread, limit)
+    VALUE thread;
+    double limit;
+{
+    if (limit < 0) limit = DELAY_INFTY;
+    return rb_thread_join0(rb_thread_check(thread), limit);
+}
+
 
 /*
@@ -11455,9 +11464,8 @@ rb_thread_join_m(argc, argv, thread)
     VALUE limit;
     double delay = DELAY_INFTY;
-    rb_thread_t th = rb_thread_check(thread);
 
     rb_scan_args(argc, argv, "01", &limit);
     if (!NIL_P(limit)) delay = rb_num2dbl(limit);
-    if (!rb_thread_join(th, delay))
+    if (!rb_thread_join0(rb_thread_check(thread), delay))
 	return Qnil;
     return thread;
Index: ext/thread/thread.c
===================================================================
--- ext/thread/thread.c	(revision 17841)
+++ ext/thread/thread.c	(working copy)
@@ -243,8 +243,11 @@ wake_all(List *list)
 }
 
+extern int rb_thread_join _((VALUE thread, double limit));
+#define DELAY_INFTY 1E30
+
 static VALUE
-wait_list_inner(List *list)
+wait_list_inner(VALUE arg)
 {
-    push_list(list, rb_thread_current());
+    push_list((List *)arg, rb_thread_current());
     rb_thread_stop();
     return Qnil;
@@ -252,8 +255,8 @@ wait_list_inner(List *list)
 
 static VALUE
-wait_list_cleanup(List *list)
+wait_list_cleanup(VALUE arg)
 {
     /* cleanup in case of spurious wakeups */
-    remove_one(list, rb_thread_current());
+    remove_one((List *)arg, rb_thread_current());
     return Qnil;
 }
@@ -391,4 +394,23 @@ rb_mutex_try_lock(VALUE self)
 }
 
+static VALUE
+wait_mutex(VALUE arg)
+{
+    Mutex *mutex = (Mutex *)arg;
+    VALUE current = rb_thread_current();
+
+    push_list(&mutex->waiting, current);
+    do {
+	rb_thread_critical = 0;
+	rb_thread_join(mutex->owner, DELAY_INFTY);
+	rb_thread_critical = 1;
+	if (!MUTEX_LOCKED_P(mutex)) {
+	    mutex->owner = current;
+	    break;
+	}
+    } while (mutex->owner != current);
+    return Qnil;
+}
+
 /*
  * Document-method: lock
@@ -411,12 +433,5 @@ lock_mutex(Mutex *mutex)
     }
     else {
-	do {
-	    wait_list(&mutex->waiting);
-	    rb_thread_critical = 1;
-	    if (!MUTEX_LOCKED_P(mutex)) {
-		mutex->owner = current;
-		break;
-	    }
-	} while (mutex->owner != current);
+	rb_ensure(wait_mutex, (VALUE)mutex, wait_list_cleanup, (VALUE)&mutex->waiting);
     }
 


-- 
--- 僕の前にBugはない。
--- 僕の後ろにBugはできる。
    中田 伸悦