[ruby-dev:13204] rb_thread_wait_other_threads() never end

前田です。

At Tue, 15 May 2001 18:49:30 +0900,
[e-mail] (Yukihiro Matsumoto) wrote:
> |Queueを同期に使っているとInterruptによって
> |Queueをにぎったままスレッドが死んでしまう一方で
> |それなのにメインスレッドだけ生きのこっていてアレレ…
> |と, そんなようなことが起こっていたように思っています
> |(rb_thread_{stop,run,schedule}あたりをぐるぐるまわっているようでした).
> 
> ふうむ。

ちょっと調べてみました。

1. rb_thread_cleanup()ですべてのスレッドのstatusがTHREAD_TO_KILL
になる。
2. rb_thread_wait_other_threads()でTHREAD_TO_KILLなスレッドに制御
がわたった時、ensureブロックでcontext switchがおこる。
3. 同じスレッドにふたたび制御がもどった時にはnext->flags &
THREAD_TERMINATINGが真なのでRESTORE_NORMALでコンテクストの復帰が
行われる。
4. そのスレッドでrb_thread_stopが呼ばれて、statusがTHREAD_STOPPED
になる。
5. main_thread以外にはTHREAD_STOPPEDなスレッドしかいないのでいつ
までたってもrb_thread_wait_other_threads()がおわらない。

ということのようです。

> やっぱりバグだと思う。でも、どうしたら良いのかはちょっと分か
> りませんけど。

rb_thread_wait_other_threads()でTHREAD_STOPPEDなスレッドのみになっ
た場合には、あきらめてしまってはどうでしょう。

--- eval.c.orig	Tue May 15 23:35:38 2001
+++ eval.c	Wed May 16 00:04:47 2001
@@ -8321,8 +8321,19 @@
 static void
 rb_thread_wait_other_threads()
 {
+    rb_thread_t th;
+    int found;
+
     /* wait other threads to terminate */
     while (curr_thread != curr_thread->next) {
+	found = 0;
+	th = curr_thread->next;
+	while (th != curr_thread) {
+	    if (th->status != THREAD_STOPPED)
+		found = 1;
+	    th = th->next;
+	}
+	if (!found) return;
 	rb_thread_schedule();
     }
 }


-- 
前田 修吾
スレッドは難しい。