lib/celluloid/tasks/task_thread.rb in celluloid-0.14.0 vs lib/celluloid/tasks/task_thread.rb in celluloid-0.14.1.pre
- old
+ new
@@ -11,9 +11,10 @@
super
end
def create
@thread = Celluloid.internal_pool.get do
+ Thread.current.role = :task
begin
ex = @resume_queue.pop
raise ex if ex.is_a?(Task::TerminatedError)
yield