ruby-list

原です。

In message "[ruby-list:15030] ConditionVariable (cv3.rb)"
    on 99/06/17, Shin-ichiro Hara <sinara@blade.nagaokaut.ac.jp> writes:

|test1.rb を改造した test-cv.rb（後掲）で、バッファサイズ３のパ
|イプに、送り手４スレッド受け手３スレッドでオブジェクトを通すも
|のです。停止するのは全ての受け手スレッドが 1000 個のオブジェク
|トを受け取った時とします。

一応 test-cv.rb です。無いよりましという程度で、必ずしもポイント
をついたいいテストプログラムというわけではありません。


幾つかパラメータをコマンドライン・パラメータに取るので、いろいろ
やってみると面白いですが、数字によって結構（数論的な？）動きがあ
ったりして、実は簡単に結論が出せません。cv3.rb はパラメータによ
らず比較的安定しているのは確かですが。もうちょっとちゃんとしたテ
ストプログラムが無いとこれ以上の効率や適正性の追求は難しそうです。

(バッファサイズ10送り手12受け手3で100回す例)
$ ruby test-cv.rb max10 s12 r3 100 cv3.rb

-------------^ test-cv.rb
#!/usr/local/bin/ruby
Thread.abort_on_exception = true

$sender_num = 4
$receiver_num = 3
$rtimes = 1000
$max = 3
$debug = 0

while para = ARGV.shift
  case para
  when /^n$/
    $no_signal_mutex = true
  when /^p$/
    $pass = true
  when /^d(\d)?$/
    $debug = ($1||1).to_i
  when /^\d+$/
    $rtimes = $&.to_i
  when /^max(\d+)$/
    $max = $1.to_i
  when /^r(\d+)$/
    $receiver_num = $1.to_i
  when /^s(\d+)$/
    $sender_num = $1.to_i
  else
    $o = para
  end
end

class Thread
  Num = [0]
  Obj2num = {Thread.current => 0}

  def Thread.start0
    Num[0] = Num[0]+1
    t = Thread.start {
      Thread.stop
      yield
    }
    Obj2num[t] = Num[0]
    t
  end

  def num
    Obj2num[self]
  end
  
  def Thread.num
    Obj2num[Thread.current]
  end
  alias to_s0 to_s
  def inspect; "#{Obj2num[self]}"; end
  def to_s; "#{Obj2num[self]}"; end
end

case $o
when /cv(\d+)/
  require $o
  $ver = $1.to_i
  $full = ConditionVariable.new
  $mutex = Mutex.new
  if $ver > 2
    $signal_param = $mutex unless $no_signal_mutex
  end
  $wait_param = $mutex
  $empty = ConditionVariable.new
when /^monitor/
  require $o
  $mutex = Monitor.new
  $full = $mutex.new_cond
  $empty = $mutex.new_cond
when /^mutex/
  require $o
  $mutex = Mutex.new
  $full = ConditionVariable.new($mutex)
  $empty = ConditionVariable.new($mutex)
else
  raise "can't get option: #$o"
end
print "TEST CONDITION VARIABLE <<< #{$o.upcase} >>>\n"
printf("Sender:%d, Receiver:%d (each receives %d times), Buffer:#$max\n",
       $sender_num, $receiver_num, $rtimes)
$queue = []

$rwaste = 0
$rwaste1 = 0
$swaste = 0
$swaste1 = 0

$snds = []
$rcvs = []
$snds_times = {}
$rcvs_times = {}

$sender_num.times do
  $snds.push Thread.start0 {
    n = 0
    $snds_times[Thread.current] = 0
    loop do
      $mutex.synchronize {
	k = 0
	while $queue.size >= $max
	  k += 1
	  if $wait_param
	    $full.wait($wait_param)
	  else
	    $full.wait
	  end
	  $swaste += 1 if k > 1
	end
	$swaste1 += 1 if k > 1
	$queue.push [n, Thread.num]
	if $queue.size >= 1 # == true
	  if $signal_param
	    $empty.signal($signal_param)
	  else
	    $empty.signal
	  end
	end
      }
      n += 1
      $snds_times[Thread.current] = n
      Thread.pass if $pass
    end
  }
end

$receiver_num.times do
  $rcvs.push Thread.start0 {
    n = 0
    $rcvs_times[Thread.current] = 0
    $rtimes.times do
      $mutex.synchronize {
	k = 0
	while $queue.size <= 0
	  k += 1
	  if $wait_param
	    $empty.wait($wait_param)
	  else
	    $empty.wait
	  end
	  $rwaste += 1 if k > 1
	end
	$rwaste1 += 1 if k > 1
	v = $queue.shift
	if $queue.size < $max
	  if $signal_param
	    $full.signal($signal_param)
	  else
	    $full.signal
	  end
	end
	printf("get %s (#%s->#%s)\n", v[0], v[1], Thread.num) if $debug > 0
      }
      n += 1
      $rcvs_times[Thread.current] = n
      Thread.pass if $pass
    end
  }
end

# START
Thread.critical = true
Thread::Obj2num.each do |t, n|
  t.wakeup if n > 0
end
Thread.critical = false

$rcvs.each do |t|
  VERSION.to_f >= 1.3 ? t.join : Thread.join(t)
end
$snds.each do |t|
  Thread.kill(t)
end

printf("Idling1: send =%2d, receive =%2d\n", $swaste1, $rwaste1)
printf("Idling2: send =%2d, receive =%2d\n", $swaste, $rwaste)
$snds.each do |t|
  printf("#%s sends %d times\n", t, $snds_times[t])
end
-------------$ test-cv.rb

以外と長かった。(^^;

Thread

Prev Next

In This Thread

Prev Next

[#14708] ruby-gtk-0.18 — "Dai.K." <MAP2303@...>

[#14713] ruby/gtk 0.18 — matz@... (Yukihiro Matsumoto)

[#14715] HTTP Client with Ruby — TAKAHASHI Masayoshi <maki@...>

[#14736] RE: UNIX-based OS on PC-98x1 (Re: [BUG] def foo; foo end; foo) — "Takehiko Ueki" <takehiko@...>

[#14737] Re: [BUG] def foo; foo end; foo — "Takehiko Ueki" <takehiko@...>

[#14739] manual bug — kikutani@...

[#14740] Re: nkf(NKF::JIS, str) — 助田 雅紀 <masaki.suketa@...>

[#14746] gsub("'", "\\'") — Toshihiko SHIMOKAWA / 下川俊彦 <toshi@...>

[#14747] Ruby-gtk の Text Widget について — Takano Naoki <takanon@...>

[#14756] Re: ちっちゃい Ruby — 中村暁史 <anakamur@...>

[#14761] CGI.rb — Wakou Aoyama <wakou@...>

[#14763] do end + do end — Wakou Aoyama <wakou@...>

[#14765] ruby 1.3.4 with ipv6 — Yasunari Momoi <momo@...>

[#14766] ruby 1.3.4 on BSD/OS 3.1 — Yasunari Momoi <momo@...>

[#14790] Microsoft Perl ? — ARIMA Yasuhiro <fit0298@...>

[#14804] telnet.rb(0.20) — Wakou Aoyama <wakou@...>

[#14821] Re: UNIX-based OS on PC-98x1 (Re: [BUG] def foo; foo end; foo) — "Takehiko Ueki" <takehiko@...>

[#14822] Re: [BUG] def foo; foo end; foo — "Takehiko Ueki" <takehiko@...>

[#14826] Re: UNIX-based OS on PC-98x1 (Re: [BUG] def foo; foo end; foo) — "Takehiko Ueki" <takehiko@...>

[#14827] ruby-gtk-0.18 — Kenji Horikoshi <k-horix@...>

[#14833] Regacy scripts depend the ruby old version. — ARIMA Yasuhiro <fit0298@...>

[#14842] texinfo document for ruby-1.3 — Koji Arai <JCA02266@...>

[#14843] Ruby/Tk TkText#dump — Tomoyuki Kosimizu <greentea@...2.so-net.ne.jp>

[#14846] Re: Microsoft Perl ? — 助田 雅紀 <masaki.suketa@...>

[#14854] Rubyfaq-990607 — Akira Endo <akendo@...3.rim.or.jp>

[#14860] CVSup server — Yasuhiro Fukuma <yasuf@...>

[#14863] OO Software Construction by Meyer — Akira Endo <akendo@...3.rim.or.jp>

[#14874] ruby-gtk trouble — Jun Adachi <adachi@...>

[#14891] Re: extension library for mutual exclusion — SHUDO Kazuyuki <shudoh@...>

[#14898] font-lock on ruby-mode — Koji Arai <JCA02266@...>

[#14900] Rubyfaq-990608 — Akira Endo <akendo@...3.rim.or.jp>

[#14908] [Q] finalizer — gotoken@... (GOTO Kentaro)

[#14917] Ruby/Tk and Threads — Tomoyuki Kosimizu <greentea@...2.so-net.ne.jp>

[#14951] Missing tag in Reference Manual — Hiramatsu Yoshifumi <hiramatsu@...>

[#14953] 男親なら誰でも思う — 中村暁史 <anakamur@...>

[#14957] textarea with CGI.rb — HATTORI Masashi <hattori@...>

[#14970] thread with curses — HATTORI Masashi <hattori@...>

[#14980] 初期化メソッドの追加 — ARIMA Yasuhiro <fit0298@...>

[#14984] rd2html — TAKAHASHI Masayoshi <maki@...>

[#14993] Rubyfaq-990611 — Akira Endo <akendo@...3.rim.or.jp>

[#14994] FreeBSD port kit for Ruby/Gtk — Yasuhiro Fukuma <yasuf@...>

[#14995] HUP シグナルを受けとってファイルの読み込みがうまくいかないのですが — Keisuke Minami <keisuke@...>

[#14996] HUP シグナルを受けとってファイルの読み込みがうまくいかないのですが — Keisuke Minami <keisuke@...>

[#14997] ruby-1.3.4-990611 bug? — a-shigi@... (A.Shigihara)

[#15001] [BUG] File のサブクラスのインスタンス変数 — "Takehiko Ueki" <takehiko@...>

[#15003] 文字列から数値への変換失敗を検出したい — ARIMA Yasuhiro <fit0298@...>

[#15005] extention for faster scan — Minero Aoki <aamine@...>

[#15012] ext ML の過去ログはいずこ？ — 中村暁史 <anakamur@...>

[#15035] [Bug] Rubyfaq-990611 — Akira Endo <akendo@...3.rim.or.jp>

[#15039] Re: [BUG] File のサブクラスのインスタンス変数 — "Takehiko Ueki" <takehiko@...>

[#15042] Ruby for Debian GNU/Linux — akira yamada / やまだあきら <akira@...>

[#15043] UDPsocket bind — HATTORI Masashi <hattori@...>

[#15044] CGI.rb — Norihito Shinzan <kabbalah@...>

[#15045] mail library — Minero Aoki <aamine@...>

[#15053] ruby 1.2.6 is out! — matz@... (Yukihiro Matsumoto)

[#15056] mod_ruby 0.1.2 — Shugo Maeda <shugo@...>

[#15057] 複雑？な構造体の定義方法 — Koichi Shigematsu <shige@...>

[#15064] hako-iri — Masatoshi SEKI <m_seki@...>

[#15067] Re: [BUG] File のサブクラスのインスタンス変数 — "Takehiko Ueki" <takehiko@...>

[#15068] command not found — 助田 雅紀 <masaki.suketa@...>

[#15074] Re: command not found — 助田 雅紀 <masaki.suketa@...>

[#15093] String#rindex with arbitrary starting point — kjana@... (YANAGAWA Kazuhisa)

[#15098] Re: HUP シグナルを受けとってファイルの読み込みがうまくいかないのですが — "NAKAMURA, Hiroshi" <nakahiro@...>

[#15101] ruby-1.3.4-990611 [BUG] Segmentation fault — Yuji Shigehiro <sigehiro@...>

[#15104] delegate.rb — Wakou Aoyama <wakou@...>

[#15107] (?: ) in regexp — Yoshiki Wada <wada@...>

[#15108] ruby-1.3.4-990611 can not compile on alphaev56-osf4.0e — Yuji Shigehiro <sigehiro@...>

[#15111] attr makes a strange name method — Yoshinori Toki <toki@...>

[#15112] pty on NeXTSTEP3.3J — SHIROYAMA Takayuki <psi@...>

[#15113] description in links.html — kjana@... (YANAGAWA Kazuhisa)

[#15116] irb & ruby — Takashi Nishimoto <g96p0935@...>

[#15117] 他のプリンタで印刷したい — Takashi Nishimoto <g96p0935@...>

[#15121] ruby-gtk-0.19 released — Hiroshi Igarashi <igarashi@...>

[#15127] RE: face mark(Re: mail library) — 助田 雅紀 <masaki.suketa@...>

[#15128] telnet.rb and using it — matz@... (Yukihiro Matsumoto)

[#15131] game of life: ruby/gtk version — Takahiro Maebashi <maebashi@...>

[#15160] undefined method `-@' for Fixnum (NameError) — Tomoyuki Kosimizu <greentea@...2.so-net.ne.jp>

[#15168] [Q] Thread and Queue — kazuo@... (Kazuo DOI)

[ruby-list:15031] Re: ConditionVariable (cv3.rb)

Thread

[#14740] Re: nkf(NKF::JIS, str) — 助田　雅紀 <masaki.suketa@...>

[#14846] Re: Microsoft Perl ? — 助田　雅紀 <masaki.suketa@...>

[#15068] command not found — 助田　雅紀 <masaki.suketa@...>

[#15074] Re: command not found — 助田　雅紀 <masaki.suketa@...>

[#15127] RE: face mark(Re: mail library) — 助田　雅紀 <masaki.suketa@...>