Project

General

Profile

Actions

Bug #595

closed

Fiber ignores ensure clause

Added by ko1 (Koichi Sasada) over 15 years ago. Updated 10 months ago.

Status:
Closed
Target version:
-
ruby -v:
-
Backport:
[ruby-dev:36511]
Tags:

Description

Ruby プロセス終了時,Fiber が ensure を無視します.
これは,前から直そうと思って手がついていなかった問題です.
10月末までには直そうと思います.結構複雑なので,後回しにしていましました.

 fib = Fiber.new{
   begin
     Fiber.yield :ok
   ensure
     puts "should be print out"
   end
 }
 p fib.resume

Files

ensure_fiber.patch (2.12 KB) ensure_fiber.patch wanabe (_ wanabe), 01/13/2010 06:45 PM
ensure_fiber2.patch (7.57 KB) ensure_fiber2.patch wanabe (_ wanabe), 08/05/2012 01:05 PM

Related issues 3 (0 open3 closed)

Related to Ruby master - Bug #10540: Yielded fibers do not execute ensure blocksClosedko1 (Koichi Sasada)Actions
Related to Ruby master - Feature #10344: [PATCH] Implement Fiber#raiseClosedioquatix (Samuel Williams)Actions
Is duplicate of Ruby master - Bug #2460: RubySpecでFiberのSpecがおちるClosedko1 (Koichi Sasada)12/08/2009Actions
Actions #1

Updated by yugui (Yuki Sonoda) over 15 years ago

  • Target version set to 1.9.1 Release Candidate

=begin

=end

Actions #2

Updated by rogerdpack (Roger Pack) over 15 years ago

=begin
Help me out--shouldn't this print out only when you call fib.resume twice?

fib = Fiber.new{
begin
Fiber.yield :ok
ensure
puts "should be print out"
end
}
p fib.resume
p fib.resume

prints out all right.
=end

Actions #3

Updated by yugui (Yuki Sonoda) over 15 years ago

  • Target version changed from 1.9.1 Release Candidate to 2.0.0

=begin

=end

Actions #4

Updated by yugui (Yuki Sonoda) over 15 years ago

=begin
パッチを書くか、もしくはドキュメントにKNOWN BUGとして書く、ということで。
=end

Actions #5

Updated by wanabe (_ wanabe) almost 15 years ago

=begin
ワナベと申します。

かなり前のチケットですが、題名の件についてパッチを書きました。
もしまだどなたもパッチを書かれていないようならご検討ください。

Index: thread.c

--- thread.c (リビジョン 23617)
+++ thread.c (作業コピー)
@@ -293,6 +293,8 @@

static void rb_mutex_unlock_all(mutex_t *mutex, rb_thread_t *th);

+void rb_fiber_terminate_all(rb_thread_t *th);
+
void
rb_thread_terminate_all(void)
{
@@ -310,6 +312,7 @@

  thread_debug("rb_thread_terminate_all (main thread: %p)\n", (void *)th);
  st_foreach(vm->living_threads, terminate_i, (st_data_t)th);
  • rb_fiber_terminate_all(th);

    while (!rb_thread_alone()) {
    PUSH_TAG();
    @@ -1210,6 +1213,7 @@
    thread_debug("rb_thread_execute_interrupts: %ld\n", err);

    if (err == eKillSignal || err == eTerminateSignal) {

  •  rb_fiber_terminate_all(th);
     th->errinfo = INT2FIX(TAG_FATAL);
     TH_JUMP_TAG(th, TAG_FATAL);
     }
    

Index: cont.c

--- cont.c (リビジョン 23617)
+++ cont.c (作業コピー)
@@ -534,6 +534,7 @@
case 0:
return Qnil;
case 1:

  •  case -1:
    
    return argv[0];
    default:
    return rb_ary_new4(argc, argv);
    @@ -946,6 +947,36 @@
    return fib->status != TERMINATED ? Qtrue : Qfalse;
    }

+static VALUE
+terminate_all_i(VALUE fibval)
+{

  • if (rb_fiber_alive_p(fibval)) {
  • VALUE value = rb_exc_new2(rb_eSystemExit, "terminate");
  • return fiber_switch(fibval, -1, &value, 0);
  • }
    +}

+void
+rb_fiber_terminate_all(rb_thread_t *th)
+{

  • VALUE fibval;
  • rb_fiber_t *fib, *root_fib;
  • rb_thread_t *_th = GET_THREAD();
  • rb_thread_set_current(th);
  • fibval = th->root_fiber;
  • if (!RTEST(fibval)) return;
  • GetFiberPtr(fibval, root_fib);
  • fib = root_fib->prev_fiber;
  • while (fib != root_fib) {
  • rb_rescue2(terminate_all_i, fib->cont.self,
  •     0, 0, rb_eSystemExit);
    
  • fib = fib->prev_fiber;
  • }
  • rb_thread_set_current(_th);
    +}

/*

  • call-seq:
  • fiber.resume(args, ...) -> obj
    

--
ワナベ

=end

Actions #6

Updated by ko1 (Koichi Sasada) almost 15 years ago

=begin
 ささだです.

 返事が随分遅くなってしまってすみません.

wanabe wrote::

かなり前のチケットですが、題名の件についてパッチを書きました。
もしまだどなたもパッチを書かれていないようならご検討ください。

 実は,以前似たようなものを作ったのですが,さくっと SEGV の嵐で,面倒く
さいなぁ,と思って放置していたのでした.このパッチですと,たとえば
test-all とかはどうでした?

--
// SASADA Koichi at atdot dot net

=end

Actions #7

Updated by wanabe (_ wanabe) almost 15 years ago

=begin
ワナベです。

2009/06/15 6:33 に SASADA Koichi さんは書きました:

wanabe wrote::

かなり前のチケットですが、題名の件についてパッチを書きました。
もしまだどなたもパッチを書かれていないようならご検討ください。

実は,以前似たようなものを作ったのですが,さくっと SEGV の嵐で,面倒く
さいなぁ,と思って放置していたのでした.このパッチですと,たとえば
test-all とかはどうでした?

ruby 1.9.2dev (2009-06-14 trunk 23691) [i386-mingw32] では
make test-all で SEGV が出てしまいました。
TestFiber#test_many_fibers_with_threads が E で終わった直後の
TestFiber#test_normal で落ちているようです。
ですがなぜか test_fiber.rb を直接起動するとエラーなしで完走します。

またパッチはLinux環境で書いたのですが、その時のmake test-allでは問題はなく、
今改めて ruby 1.9.2dev (2009-06-15 trunk 23692) [i686-linux] で試してみても
SEGV は発生しませんでした。

どういう事かよく分かりませんが、不安定であることは間違いないので
このパッチは役に立たなさそうです。申し訳ありません。

--
ワナベ

=end

Actions #8

Updated by ko1 (Koichi Sasada) almost 15 years ago

=begin
 ささだです.

wanabe wrote::

ruby 1.9.2dev (2009-06-14 trunk 23691) [i386-mingw32] では
make test-all で SEGV が出てしまいました。
TestFiber#test_many_fibers_with_threads が E で終わった直後の
TestFiber#test_normal で落ちているようです。
ですがなぜか test_fiber.rb を直接起動するとエラーなしで完走します。

またパッチはLinux環境で書いたのですが、その時のmake test-allでは問題はなく、
今改めて ruby 1.9.2dev (2009-06-15 trunk 23692) [i686-linux] で試してみても
SEGV は発生しませんでした。

どういう事かよく分かりませんが、不安定であることは間違いないので
このパッチは役に立たなさそうです。申し訳ありません。

 いえいえ.もうちょっと追跡すればなんとかなると思うのですが,ここはどう
にも難しいですよね.Fiber の集合を保存する,私が最後にあわてて突っ込んだ
部分にバグがあるような気がしています.

 1.9.2 には間に合わせたいところ.

--
// SASADA Koichi at atdot dot net

=end

Actions #9

Updated by wanabe (_ wanabe) about 14 years ago

=begin
以前このチケットについて書いたパッチが SEGV すると書きましたが、
パッチの問題ではなく Bug #1325 の影響だったようです。
改めて確認したところ make test-all では SEGV しませんでした。

それとは別の問題として、例外でジャンプさせると rescue される恐れがあったので
throw/catch を使うように変更したパッチを添付します。
ご検討くだされば幸いです。
=end

Actions #10

Updated by wanabe (_ wanabe) about 14 years ago

  • File deleted (ensure_fiber.patch)

=begin

=end

Actions #11

Updated by wanabe (_ wanabe) almost 14 years ago

=begin
ささださん

このチケットおよびパッチについてコメントいただければ幸いです。
この対処で問題ないかどうか、もし問題ないとしたら
1.9.2 リリース前に入れるべきかどうかが気になっています。
そもそもアプローチがまずいようでしたら別の方法を考えます。
=end

Actions #12

Updated by mame (Yusuke Endoh) almost 14 years ago

=begin
遠藤です。

2010年4月10日23:20 _ wanabe :

ささださん

このチケットおよびパッチについてコメントいただければ幸いです。
この対処で問題ないかどうか、もし問題ないとしたら
1.9.2 リリース前に入れるべきかどうかが気になっています。
そもそもアプローチがまずいようでしたら別の方法を考えます。

ささださんではないですが勝手にコメントします。

  1. プロセス終了時でなく、Fiber が GC で回収される時に ensure 節が
    実行されません。

1000.times do
Fiber.new do
begin
Fiber.yield
ensure
puts "foo!"
end
end.resume
GC.start
end

foo! が 1 個しか出ない (期待は 1000 個)

$ ./ruby t.rb
foo!

実行中の Thread と同様に、yield 中の Fiber は GC しないようにする
くらいしか思いつきません。

  1. Fiber を作ったスレッドが終了した場合、Fiber の ensure 節が実行
    されません。

Thread.new do
Fiber.new do
begin
Fiber.yield
ensure
puts "foo!"
end
end.resume
end
sleep 1
puts "end"

foo! が出ない

$ ./ruby t.rb
end

プロセスの終了時でなく、スレッドの終了時に Fiber を起こさないと
行けない?

どちらも仕様レベルで検討しないといけないことのような気がします。
まだ結構大変そうなので、1.9.2 は見送った方がいいんじゃないかなと
思います。早くコメントしていれば、wanabe さんなら余裕で直せたと
思うので残念ですが。

--
Yusuke Endoh

=end

Actions #13

Updated by ko1 (Koichi Sasada) almost 14 years ago

=begin
(2010/04/21 23:55), Yusuke ENDOH wrote::

どちらも仕様レベルで検討しないといけないことのような気がします。
まだ結構大変そうなので、1.9.2 は見送った方がいいんじゃないかなと
思います。早くコメントしていれば、wanabe さんなら余裕で直せたと
思うので残念ですが。

 返事が出来ていなくてすみません.最近,色々と余裕がなくて,じっくり考え
て返事が出来ず.

--
// SASADA Koichi at atdot dot net

=end

Actions #14

Updated by shyouhei (Shyouhei Urabe) over 13 years ago

  • Status changed from Open to Assigned

=begin

=end

Updated by ko1 (Koichi Sasada) almost 13 years ago

未だに考え中ですが,これは 1.9.3 には仕様変更になるので入りませんよね?

Updated by matz (Yukihiro Matsumoto) almost 13 years ago

  • ruby -v changed from ruby 1.9.2dev (2010-01-13) [i386-mingw32] to -

Updated by matz (Yukihiro Matsumoto) almost 13 years ago

まつもと ゆきひろです

In message "Re: [ruby-dev:43715] [Ruby 1.9 - Bug #595] Fiber ignores ensure clause"
on Sat, 11 Jun 2011 14:52:03 +0900, Koichi Sasada writes:

|未だに考え中ですが,これは 1.9.3 には仕様変更になるので入りませんよね?

この動作はバグだと考えているので、Yuguiさんが拒絶しない限り、
直せるのであれば1.9.3で直せばよいと思います。間に合わないな
らしょうがない。

Updated by naruse (Yui NARUSE) almost 13 years ago

RubySpec 的にバグ扱いになってますね。
core/fiber/resume_spec.rb

Updated by nahi (Hiroshi Nakamura) over 12 years ago

  • Target version changed from 2.0.0 to 1.9.3
Actions #20

Updated by kosaki (Motohiro KOSAKI) over 12 years ago

  • Status changed from Assigned to Closed

Updated by naruse (Yui NARUSE) about 12 years ago

  • Status changed from Closed to Assigned
  • Target version changed from 1.9.3 to 3.0

Updated by ko1 (Koichi Sasada) over 11 years ago

あれ,これ 3.0 でいいんだっけ.

Updated by naruse (Yui NARUSE) over 11 years ago

ko1 (Koichi Sasada) wrote:

あれ,これ 3.0 でいいんだっけ.

3月に話したときに大変そうだから先かなー的な雰囲気のことを仰っていたので、3.0かなぁ、と。
早く直るに越した事はありません。

Updated by wanabe (_ wanabe) over 11 years ago

ワナベと申します。

(1) GC で mark と sweep の間に、mark されていない Fiber を対象に
(2) ruby_cleanup 中に、メインスレッドに所属するすべての Fiber を対象に
(3) 子スレッド終了時(vm->living_threads から外されるとき)、所属するすべての Fiber を対象に
の 3 つのタイミングで、throw/catch により ensure 節を実行するパッチを書きました。

[ruby-dev:41035] で遠藤さんがおっしゃっているような「yield 中の Fiber は GC しない」
という手法もやってみたのですが、test/ruby/test_fiber.rb がとても終わりそうにないことや
Fiber のマーク処理の重さや Fiber 自体のメモリ消費量などにより、断念しました。
そのため上記(1)のように、rb_gc_marked_p() という関数が必要になるなど強引な手段を使っています。

また、以下のようにして速度低下を計ってみました。

require "benchmark"
GC.start
Benchmark.bm(4) do |x|
tms = Benchmark::Tms.new
10.times do |i|
tms += x.report(" #{i}:") do
30000.times do
Fiber.new{Fiber.yield}.resume
end
end
end
puts " sum:#{tms}"
end

素の r36623 :2.980000 3.120000 6.100000 ( 6.107164)
パッチ適用後:3.580000 3.480000 7.060000 ( 7.061093)

と、無視できない程度に(約 14%)速度低下してしまいました。
とはいえこれ以上の方法は思いつかないのですが、いかがでしょうか。

Updated by ko1 (Koichi Sasada) over 11 years ago

こちら,返事が大変遅くなって済みません.

(2012/08/05 13:05), wanabe (_ wanabe) wrote:

(1) GC で mark と sweep の間に、mark されていない Fiber を対象に
(2) ruby_cleanup 中に、メインスレッドに所属するすべての Fiber を対象に
(3) 子スレッド終了時(vm->living_threads から外されるとき)、所属するすべての Fiber を対象に
の 3 つのタイミングで、throw/catch により ensure 節を実行するパッチを書きました。

[ruby-dev:41035] で遠藤さんがおっしゃっているような「yield 中の Fiber は GC しない」
という手法もやってみたのですが、test/ruby/test_fiber.rb がとても終わりそうにないことや
Fiber のマーク処理の重さや Fiber 自体のメモリ消費量などにより、断念しました。
そのため上記(1)のように、rb_gc_marked_p() という関数が必要になるなど強引な手段を使っています。

 とりとめもなく3つほど.

 (1) ですが,ファイナライザのように実行するのはどうかと思っておりまし
た.ただ,その場合,ちょっと管理が大変なんですよね.

 あと,throw よりは,

#define eKillSignal INT2FIX(0)
#define eTerminateSignal INT2FIX(1)

この辺がいいのかなぁ,と思っていました.いや,むしろここを thorw にした
ほうが設計は綺麗かもしれませんね....現在のの実装は,絶対 catch 出来な
い,ってのを目指している感じです.

 速度ですが,小崎さんが仰っているように,あまり気にしてもしょうがない,
という気もするのですが,例えば ensure 節でひっかける可能性があるか,とい
うチェックをするのは結構効くのではないかと思っています.

 というのも,殆どの用途はガチで使っているわけじゃないと思うので,ensure
な処理を必要とする Fiber は,実は少ないのではないかと,

 別の案としては,Fiber 生成時に「ensure ちゃんと処理して」フラグを新設
し,ガチで使う人(ensure をきっちり動かして欲しい人)はこれでやってね
(参考: http://bugs.ruby-lang.org/issues/6694),というのはどうだろう,
とか思うんですが,ちょっと手抜きしすぎでしょうか.

--
// SASADA Koichi at atdot dot net

Actions #26

Updated by funny_falcon (Yura Sokolov) about 10 years ago

What about this ticket?
Guaranteed ensure inside of Fiber and Fiber.raise (as complement for Thread.raise) will be usefull for full coroutine based environment ala python's gevent.

Updated by Eregon (Benoit Daloze) over 8 years ago

Could we clarify what is the desired behavior and what prevents it to be implemented?

There is a very old RubySpec about this and I would like to know whether this might be guaranteed in a future release or not.

Updated by ko1 (Koichi Sasada) about 7 years ago

  • Description updated (diff)

そろそろ手をつけようかなぁ。

Actions #29

Updated by ko1 (Koichi Sasada) about 7 years ago

  • Related to Bug #10540: Yielded fibers do not execute ensure blocks added

Updated by normalperson (Eric Wong) over 5 years ago

Koichi Sasada wrote:

Bug #595: Fiber ignores ensure clause
http://redmine.ruby-lang.org/issues/595

What's the status of this? (I don't understand Japanese)

It will be difficult/unsafe to use auto-fiber/Thread::Coro
[Feature #13618] without this

Is it a performance problem holding it back?
We have ccan/list nowadays, so maybe I will try to make it fast.

Updated by normalperson (Eric Wong) over 5 years ago

Eric Wong wrote:

It will be difficult/unsafe to use auto-fiber/Thread::Coro
[Feature #13618] without this

I think I can get around this by making iom a GC root,
so all auto-yielded Fibers get marked.

Updated by normalperson (Eric Wong) over 5 years ago

Eric Wong wrote:

It will be difficult/unsafe to use auto-fiber/Thread::Coro
[Feature #13618] without this

I think I can get around this by making iom a GC root,
so all auto-yielded Fibers get marked.

Btw, I worked around this by making all auto-Fibers markable
from rb_thread_t.

However, I'm also working on making all sleeping functions
(native_sleep/rb_wait_for_single_fd/rb_thread_fd_select) method
perform auto-Fiber scheduling.

Unfortunately, that still interacts badly when people use
regular ("manual") Fibers because I/O scheduling depend on
rb_ensure heavily... So shrug I'll have to think of
something...

Updated by normalperson (Eric Wong) over 5 years ago

However, I'm also working on making all sleeping functions
(native_sleep/rb_wait_for_single_fd/rb_thread_fd_select) method
perform auto-Fiber scheduling.

Unfortunately, that still interacts badly when people use
regular ("manual") Fibers because I/O scheduling depend on
rb_ensure heavily... So shrug I'll have to think of
something...

Not auto-calling fiber_switch from regular Fiber seems
to do the trick. Need to avoid infinite loops from regular
Fibers, though...

Updated by ioquatix (Samuel Williams) over 5 years ago

In a GC language, it's impossible to ensure this, unless you want the GC to invoke some functionality.

I suggest adding something like Fiber#stop which causes internally Fiber#resume to raise exception.

It should be up to user code to deal with this IMHO, e.g.

fib = Fiber.new{
  begin
    Fiber.yield :ok
  ensure
    puts "should be print out"
  end
}
begin
  p fib.resume
ensure
  fib.stop
end

I believe there is no logical solution to avoid this issue except making it explicit of consumer of fiber. It's the same reason why we should do the following:

f = File.open
begin
  f.write "..."
ensure
  f.close
end
Actions #35

Updated by ioquatix (Samuel Williams) about 5 years ago

Updated by ioquatix (Samuel Williams) about 5 years ago

  • Assignee changed from ko1 (Koichi Sasada) to ioquatix (Samuel Williams)

While it's not possible unless we invoke functionality from the GC, if/when we merge https://bugs.ruby-lang.org/issues/10344 it should become simple to do the following

while fiber.alive?
    fiber.raise(Exception, "Time to die")
end

This would guarantee all ensure blocks are executed.

In theory you could implement fiber.kill which does this, and then invoke that from the GC in the finaliser.. but might be unexpected for user.

Updated by ioquatix (Samuel Williams) about 5 years ago

  • Target version set to 2.7

After discussion, we decided that:

  • Doing this in the GC is probably a bad idea.
  • Ruby's general model for resource management is explicit, e.g. f = File.open; f.close or File.open do |f| ... end. The same model should apply to Fiber.
  • We can implement something like Fiber.kill or Fiber.close which essentially invokes Fiber.raise(Exception) until the Fiber is dead.

We will test these ideas during 2.7 release. If there are any further thoughts about this approach, please feel free to add them here.

Updated by naruse (Yui NARUSE) about 5 years ago

  • Target version deleted (2.7)

Target version is used by release engineering; don't use this as just a goal.

Actions #39

Updated by hsbt (Hiroshi SHIBATA) about 4 years ago

  • Tags set to fiber
Actions

Also available in: Atom PDF

Like0
Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0Like0