[ruby-dev:12460] Re: at_exit

けいじゅ＠日本ラショナルソフトウェアです.

In [ruby-dev :12443 ] the message: "[ruby-dev:12443] Re: at_exit ", on
Mar/13 01:51(JST) Yukihiro Matsumoto writes:

>まつもと ゆきひろです

>|と思いましたが. 今一です...
>|
>|Thread.start do
>|  begin
>|    ...
>|  ensure
>|    ...
>|  end
>|end
>|
>|でensure(rescueでもよし)プロセスの終了時に呼ばれているのか, スレッドが本
>|当に終わっているのか, はたまた例外なのかが簡単にわかる方法ってあります?
>
>えーと、
>
>>どういうシチュエーションでなにが必要なのかもうちょっとはっき
>>りするといいかもしれませんね。
>
>を繰り返さざるをえません。(自分で決めた)解答から始めるんじゃ
>なくて、解決したい問題から始めてくださいな。本当に区別する必
>要があるんですか？

何をやっているかというと, 昔shell.rbってありましたよね
[ruby-list:7262]. 松本さんも絶賛で[ruby-list:7263], つい最近まで標準添付
ライブラリになっていたのですが...  知らないうちに標準添付から外されてい
まいました(;_; で, 悔しかったので完全版を作成中です. おかげさまで, ほと
んどの問題は解決したんですが, まだ問題が幾つか残っていまして...

まず, Shellの動作原理ですが....

  sh.cat("/etc/printcap") | sh.tee("tee1") >> "tee2"

みたいなこととか

  print sh.cat("/etc/passwd").head.collect{|l| l =~ /keiju/}

みたいなことができるように, パイプの処理は別スレッドで行っています. とい
うのも, 

  sh.cat("/etc/printcap") | sh.tee("tee1") >> "tee2"

は, sh.cat("/etc/printcap"), sh.tee("tee1"), "tee2" が実行されて, そのあ
と >>, | の順に実行されるので, コマンドの実行後にpipeの結合が行われるか
らです. それなら, pipe結合されるまで実行しなければいいんでは? って話もあ
るかもしれませんが, そうでもなく, 上記で sh.cat... が実行された後,
pipeされるかどうかはわかりません. それで何をやっているかというと

sh.cat を実行するとすぐその結果を親プロセス側のQueueにいれてバッファリ
ングしはじめます, で, そのあと sh.tee も同様に行い | が来たときに上記
Queueの内容をsh.teeに出力するようにしています.

そうすると, 基本的な動作はOKなんですが... まだプロセス終了の問題がありま
して... 

上記の処理はすべて裏方threadが行っていますので, メインスレッドが終了する
と, プロセスが終了しちゃいますので裏方threadが幾ら仕事をしたいと言っても,
とまっちゃうんですよね... すると, 実行中のコマンドもIOがcloseされて止っ
てしまうと...

で今やっているのが, 以下の感じとか

## waitpid部分
      th = Thread.start {
	begin
#	  @job_monitor.synchronize do
	    _pid = nil
	    begin
	      _pid = Process.waitpid(pid, nil)
	    rescue Errno::ECHILD
	      print "shell: warn: job#{command.name}(#{pid}) was done already waitipd.\n" if @shell.verbose?
	      _pid = true
	    ensure
	      # プロセス終了時にコマンド実行が終わるまで待たせるため.
	      raise AT_EXIT unless _pid
	      terminate_job(command)
#	      @job_condition.signal
	      printf "Finish: %d\n", pid if @shell.debug?
	    end
#	  end
	rescue AT_EXIT
	  retry
	end
      }

こんなかんじとか...

## pipe読み込み部分
      Thread.start {
	print "<imp##{@command}>\n" if @shell.debug?
	rs = @shell.record_separator unless rs
	loop do
	  begin
	    eop = true
	    while l = @pipe_in.gets
	      @input_queue.push l
	    end
	    eop = false
	  rescue Errno::EPIPE
	    eop = false
	  ensure
	    next if eop

	    print "EOF##{@command}\n" if @shell.debug?
	    @input_queue.push :EOF
	    @pipe_in.close
	    break
	  end
	end
      }

で, 一応実現できているのですが, もうちょっとどうにかならんかと....


__
..............................石塚 圭樹＠日本ラショナルソフトウェア...
----------------------------------->> e-mail: [e-mail] <<---