active?()
click to toggle source
assert_active()
click to toggle source
def assert_active
fail Celluloid::NotActive unless active?
end
assert_inactive()
click to toggle source
def assert_inactive
return unless active?
if RUBY_PLATFORM == "java"
Celluloid.logger.warn "Group is still active"
else
fail Celluloid::StillActive
end
end
create()
click to toggle source
def create
fail NotImplementedError
end
each() { |thread| ... }
click to toggle source
def each
to_a.each { |thread| yield thread }
end
each_actor(&block)
click to toggle source
def each_actor(&block)
to_a.lazy.select { |t| t[:celluloid_role] == :actor }.each(&block)
end
get()
click to toggle source
def get
fail NotImplementedError
end
purge(thread)
click to toggle source
def purge(thread)
@mutex.synchronize do
@group.delete(thread)
thread.kill rescue nil
end
end
shutdown()
click to toggle source
def shutdown
fail NotImplementedError
end
to_a()
click to toggle source
def to_a
res = nil
@mutex.synchronize { res = @group.dup }
res
end