Sha256: a475545c090473972e3244a5ed373872347cfc162b8be147a1676de970f96172
Contents?: true
Size: 478 Bytes
Versions: 8
Compression:
Stored size: 478 Bytes
Contents
module Mutant
module Actor
# Sender for messages to acting thread
class Sender
include Adamantium::Flat, Concord.new(:condition_variable, :mutex, :messages)
# Send a message to actor
#
# @param [Object] message
#
# @return [self]
def call(message)
mutex.synchronize do
messages << message
condition_variable.signal
end
self
end
end # Sender
end # Actor
end # Mutant
Version data entries
8 entries across 8 versions & 1 rubygems