module Af::QThread::Interface
Public Instance Methods
has_message?()
click to toggle source
# File lib/fiksu-af/q_thread/interface.rb, line 3 def has_message? return !queue.empty? end
post_data_message(data, from = Thread.current)
click to toggle source
# File lib/fiksu-af/q_thread/interface.rb, line 19 def post_data_message(data, from = Thread.current) post_message(::Af::QThread::Message.new(data, from)) end
post_message(message)
click to toggle source
# File lib/fiksu-af/q_thread/interface.rb, line 11 def post_message(message) queue << message end
read_message()
click to toggle source
# File lib/fiksu-af/q_thread/interface.rb, line 7 def read_message return queue.pop end
requeue(message)
click to toggle source
# File lib/fiksu-af/q_thread/interface.rb, line 15 def requeue(message) post_message(message) end