[ruby-dev:21922] Re: pthread trouble on tcltklib

永井@知能．九工大です．

From: [e-mail]
Subject: [ruby-dev:21916] Re: pthread trouble on tcltklib
Date: Wed, 12 Nov 2003 15:56:54 +0900
Message-ID: <[e-mail]>
> > # 当面は Tietew さんの patch を適用していただくだけで
> > # きっと十分なんでしょうね．
> 当面は足りるのではないかと思います。

え〜っと，誰が commit すべきなのかわかりませんでしたので
そのままにしていましたが，commit の気配がないので
とりあえず patch にしてみました．

元の Tietew さんの patch だと，eval.c の rb_thread_check() と
衝突するので rb_nativethread_check() (および NATIVETHREAD_CHECK) に
名前を変えています．
また，ruby_thid の宣言で (rb_nativethread_t)0 で初期化するように
加えています．

configure.in では相変わらず --with-pthread-ext が付与されたときだけ
HAVE_LIBPTHREAD のチェックをする (FreeBSD を除く) ようになってますが，
このチェックはデフォルトで行っても問題はないようにも見えます．

ところで Tietew さんの patch では，rb_nativethread_check で
ruby の native thread 以外から rb_thread_schedule() や rb_gc() が
呼ばれた時点で rb_bug で落ちるようになってますよね．
これ，もう少し救ってあげれないかと考えていたのですが
( 例えば，rb_gc なりを呼び出しを pending してその native thread を 
wait させ，ruby の native thread で rb_gc なりが終了した時点で 
起こして return する等 )，GC 中に別の native thread でオブジェクトを
いじってしまう危険がある (ですよね？) 点が消えずに残るということで
あきらめました．

Index: ruby.h
===================================================================
RCS file: /src/ruby/ruby.h,v
retrieving revision 1.90
diff -u -r1.90 ruby.h
--- ruby.h	14 Oct 2003 02:53:53 -0000	1.90
+++ ruby.h	14 Nov 2003 02:28:13 -0000
@@ -671,6 +671,22 @@
 static char *dln_libs_to_be_linked[] = { EXTLIB, 0 };
 #endif
 
+#if defined(HAVE_LIBPTHREAD)
+typedef pthread_t rb_nativethread_t;
+# define NATIVETHREAD_CURRENT() pthread_self()
+# define HAVE_NATIVETHREAD
+#elif defined(_WIN32) || defined(__CYGWIN__)
+typedef DWORD rb_nativethread_t;
+# define NATIVETHREAD_CURRENT() GetCurrentThreadId()
+# define HAVE_NATIVETHREAD
+#endif
+#ifdef HAVE_NATIVETHREAD
+extern void rb_nativethread_check _(());
+# define NATIVETHREAD_CHECK rb_nativethread_check()
+#else
+# define NATIVETHREAD_CHECK
+#endif
+
 #if defined(__cplusplus)
 }  /* extern "C" { */
 #endif
Index: eval.c
===================================================================
RCS file: /src/ruby/eval.c,v
retrieving revision 1.586
diff -u -r1.586 eval.c
--- eval.c	6 Nov 2003 16:08:26 -0000	1.586
+++ eval.c	14 Nov 2003 02:28:15 -0000
@@ -33,10 +33,6 @@
 #include "st.h"
 #include "dln.h"
 
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-#include <pthread.h>
-#endif
-
 #ifdef __APPLE__
 #include <crt_externs.h>
 #endif
@@ -8610,11 +8606,6 @@
     return test;
 }
 
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-static pthread_t thid;
-static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;
-#endif
-
 void
 rb_thread_schedule()
 {
@@ -8631,10 +8622,8 @@
     int n, max;
     int need_select = 0;
     int select_timeout = 0;
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-    int st;
-#endif
 
+    NATIVETHREAD_CHECK;
     rb_thread_pending = 0;
     if (curr_thread == curr_thread->next
 	&& curr_thread->status == THREAD_RUNNABLE)
@@ -8643,16 +8632,6 @@
     next = 0;
     curr = curr_thread;		/* starting thread */
 
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-    if ((st = pthread_mutex_trylock(&mtx)) == EBUSY) {
-	if (pthread_self() != thid) {
-	    return;
-	}
-    } else {
-	thid = pthread_self();
-    }
-#endif
-
     while (curr->status == THREAD_KILLED) {
 	curr = curr->prev;
     }
@@ -8850,22 +8829,12 @@
     }
     next->wait_for = 0;
     if (next->status == THREAD_RUNNABLE && next == curr_thread) {
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-	if (st != EBUSY) {
-	    pthread_mutex_unlock(& mtx);
-	}
-#endif
 	return;
     }
 
     /* context switch */
     if (curr == curr_thread) {
 	if (THREAD_SAVE_CONTEXT(curr)) {
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-	    if (st != EBUSY) {
-		pthread_mutex_unlock(& mtx);
-	    }
-#endif
 	    return;
 	}
     }
@@ -8875,19 +8844,9 @@
 	if (!(next->flags & THREAD_TERMINATING)) {
 	    next->flags |= THREAD_TERMINATING;
 	    /* terminate; execute ensure-clause if any */
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-	    if (st != EBUSY) {
-		pthread_mutex_unlock(& mtx);
-	    }
-#endif
 	    rb_thread_restore_context(next, RESTORE_FATAL);
 	}
     }
-#if defined(HAVE_LIBPTHREAD) && defined(USE_PTHREAD_EXTLIB)
-    if (st != EBUSY) {
-	pthread_mutex_unlock(& mtx);
-    }
-#endif
     rb_thread_restore_context(next, RESTORE_NORMAL);
 }
 
Index: gc.c
===================================================================
RCS file: /src/ruby/gc.c,v
retrieving revision 1.160
diff -u -r1.160 gc.c
--- gc.c	20 Oct 2003 02:06:39 -0000	1.160
+++ gc.c	14 Nov 2003 02:28:15 -0000
@@ -1216,6 +1216,7 @@
     jmp_buf save_regs_gc_mark;
     SET_STACK_END;
 
+    NATIVETHREAD_CHECK;
     if (dont_gc || during_gc) {
 	if (!freelist) {
 	    add_heap();
@@ -1316,6 +1317,16 @@
     return Qnil;
 }
 
+#ifdef HAVE_NATIVETHREAD
+static rb_nativethread_t ruby_thid = (rb_nativethread_t)0;
+void
+rb_nativethread_check()
+{
+    if (!ruby_thid || ruby_thid != NATIVETHREAD_CURRENT())
+	rb_bug("cross-thread violation.");
+}
+#endif
+
 void
 Init_stack(addr)
     VALUE *addr;
@@ -1353,6 +1364,10 @@
     if (STACK_LEVEL_MAX > IA64_MAGIC_STACK_LIMIT)
 	STACK_LEVEL_MAX = IA64_MAGIC_STACK_LIMIT;
 #endif
+#endif
+#ifdef HAVE_NATIVETHREAD
+    if (ruby_thid) rb_nativethread_check();
+    else ruby_thid = NATIVETHREAD_CURRENT();
 #endif
 }
 
Index: configure.in
===================================================================
RCS file: /src/ruby/configure.in,v
retrieving revision 1.191
diff -u -r1.191 configure.in
--- configure.in	8 Nov 2003 04:53:14 -0000	1.191
+++ configure.in	14 Nov 2003 02:28:16 -0000
@@ -662,9 +662,6 @@
 ], rb_cv_stack_grow_dir=-1, rb_cv_stack_grow_dir=+1, rb_cv_stack_grow_dir=0)])
 AC_DEFINE_UNQUOTED(STACK_GROW_DIRECTION, $rb_cv_stack_grow_dir)
 
-dnl default value for $KANJI
-DEFAULT_KCODE="KCODE_NONE"
-
 AC_ARG_WITH(pthread-ext, 
 	[  --with-pthread-ext      use pthread library on external modules ],
 	[AC_DEFINE(USE_PTHREAD_EXTLIB)
@@ -688,26 +685,39 @@
 	       AC_DEFINE(_THREAD_SAFE)
 	       AC_DEFINE(HAVE_LIBPTHREAD)
 	    else
-		AC_CHECK_LIB(c_r, pthread_mutex_init, 
+		AC_CHECK_LIB(c, pthread_mutex_init, 
 			     rb_use_pthread_ext=yes, rb_use_pthread_ext=no)
 		if test "$rb_use_pthread_ext" = "yes"; then
-		   if test "$with_libc_r" = "yes"; then
-		      if test "$rb_cv_supplementary_lib_c_r" = "yes"; then
+		   AC_DEFINE(_REENTRANT)
+		   AC_DEFINE(_THREAD_SAFE)
+		   AC_DEFINE(HAVE_LIBPTHREAD)
+		else
+		   AC_CHECK_LIB(c_r, pthread_mutex_init, 
+				rb_use_pthread_ext=yes, rb_use_pthread_ext=no)
+		   if test "$rb_use_pthread_ext" = "yes"; then
+		      if test "$with_libc_r" = "yes"; then
+		         if test "$rb_cv_supplementary_lib_c_r" = "yes"; then
+			    AC_DEFINE(_REENTRANT)
+			    AC_DEFINE(_THREAD_SAFE)
+			    AC_DEFINE(HAVE_LIBPTHREAD)
+			    MAINLIBS="-pthread $MAINLIBS"
+			 fi
+		      else
+		         MAINLIBS="-pthread $MAINLIBS"
 			 AC_DEFINE(_REENTRANT)
 			 AC_DEFINE(_THREAD_SAFE)
 			 AC_DEFINE(HAVE_LIBPTHREAD)
-			 MAINLIBS="-pthread $MAINLIBS"
 		      fi
 		   else
-		      MAINLIBS="-pthread $MAINLIBS"
-		      AC_DEFINE(_REENTRANT)
-		      AC_DEFINE(_THREAD_SAFE)
-		      AC_DEFINE(HAVE_LIBPTHREAD)
+		      AC_MSG_WARN("Don't know how to find pthread library on your system -- thread support disabled")
 		   fi
 		fi
 	    fi
 	 fi
 	])
+
+dnl default value for $KANJI
+DEFAULT_KCODE="KCODE_NONE"
 
 AC_ARG_WITH(default-kcode, 
 	[  --with-default-kcode=CODE specify default value for \$KCODE (utf8|euc|sjis|none)], 

-- 
                                         永井 秀利 （九工大 知能情報）
                                             [e-mail]