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