Method: Concurrent::Actor::Core#schedule_execution

Defined in:
lib/concurrent-ruby-edge/concurrent/actor/core.rb

#schedule_execution ⇒ Object

Schedules blocks to be executed on executor sequentially, sets Actress.current



114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
 
# File 'lib/concurrent-ruby-edge/concurrent/actor/core.rb', line 114

def schedule_execution
  @serialized_execution.post(@executor) do
    synchronize do
      begin
        Thread.current[:__current_actor__] = reference
        yield
      rescue => e
        log FATAL, e
      ensure
        Thread.current[:__current_actor__] = nil
      end
    end
  end

  nil
end