获取Fiber实例的状态编号，定义alive?

fux2

根据官方文档：http://ruby-doc.org/core-2.2.0/Fiber.html
使用fiber实例的alive?方法需要

You need to require 'fiber' before using this method.

有时候VA里也需要这么个操作，所以就出现了下面的玩意儿
思路也很简单，因为在resume一个status为TERMINATED的fiber时，会抛出dead fiber异常，
也就是说本身Fiber就存在判定自身状态的方法。通过这个提示的位置逆向出储存状态编号的地址，接着根据官方提供的源码逻辑，来定义alive?方法

RUBY 代码复制

class Fiber
 
  Memcopy = Win32API.new('kernel32','RtlMoveMemory','pll','l')
 
  CREATING = 0
  RUNNING = 1
  TERMINATED = 2
 
  def status
    buf = "\0"*4
    Memcopy.call(buf,self.object_id*2+16,4)
    objPtr = buf.unpack("L").first
    return 0 if objPtr == 0
    Memcopy.call(buf,objPtr+480,4)
    return buf.unpack("L").first
  end
 
  def alive?
    return self.status != TERMINATE
  end
 
end

class Fiber


 


  Memcopy = Win32API.new('kernel32','RtlMoveMemory','pll','l')


 


  CREATING = 0


  RUNNING = 1


  TERMINATED = 2


 


  def status


    buf = "\0"*4


    Memcopy.call(buf,self.object_id*2+16,4)


    objPtr = buf.unpack("L").first


    return 0 if objPtr == 0


    Memcopy.call(buf,objPtr+480,4)


    return buf.unpack("L").first


  end


 


  def alive?


    return self.status != TERMINATE


  end


 


end

guoxiaomi

写了几天上论坛一搜Fiber，果然造了轮子……本意是准备写一个桌游模拟器，但是想在游戏主流程结算卡住的时候也能打开菜单或者播放动画等，所以决定使用Fiber。
然后发现坑爹的rgss3居然没有alive?和current方法，跟文档上不一致啊哭……

Fiber_Tree

定义好process后，简单的写一个scene就可以调用了。Fiber有3种唤起模式：start，join，listen。Fiber.yield里抛出一个lambda表达式作为此fiber的苏醒条件。

2021/05/26：修复了几个BUG。黄鸡说得对，这种东西自己实现一遍理解会更深。这些代码就给后来的人做个参考吧。

shitake

1.       @fiber = Fiber.new do
   
2.         @callback.call(helper, info)
   
3.         @fiber = nil
   
4.       end

复制代码

弱鸡如我就用这样的土办法了

chd114

和dead取反的区别是什么呢？

⑨姐姐

也来回复一下自己写的不用黑科技的#alive，以及带了个::current和::fork

RUBY 代码复制

class Fiber
  @@call_stack = []
 
  attr_accessor :alive
  attr_accessor :children
 
  alias old_initialize initialize
  def initialize(&block)
    old_initialize(&block)
    @alive = true
    @children = []
  end
 
  def self.current
    @@call_stack.last
  end
 
  alias old_resume resume
  def resume
    @@call_stack.push(self)
    @children.each { |child|
      child.resume
    }
    @children.delete_if { |child|
      !child.alive
    }
    begin
      old_resume
    rescue FiberError => e
      @alive = false
    end
    @@call_stack.pop
  end
 
  def self.fork(&block)
    if Fiber.current
      child = Fiber.new(&block)
      Fiber.current.children << child
      child.resume
    end
  end
end

class Fiber


  @@call_stack = []


 


  attr_accessor :alive


  attr_accessor :children


 


  alias old_initialize initialize


  def initialize(&block)


    old_initialize(&block)


    @alive = true


    @children = []


  end


 


  def self.current


    @@call_stack.last


  end


 


  alias old_resume resume


  def resume


    @@call_stack.push(self)


    @children.each { |child|


      child.resume


    }


    @children.delete_if { |child|


      !child.alive


    }


    begin


      old_resume


    rescue FiberError => e


      @alive = false


    end


    @@call_stack.pop


  end


 


  def self.fork(&block)


    if Fiber.current


      child = Fiber.new(&block)


      Fiber.current.children << child


      child.resume


    end


  end


end

测试代码