Class: Af::QThread::Base

Inherits:

Thread

• Object
• Thread
• Af::QThread::Base

Includes:

Interface

Defined in:

lib/fiksu-af/q_thread/base.rb

Instance Attribute Summary

• #queue ⇒ Object readonly

  Returns the value of attribute queue.

Instance Method Summary

• #initialize ⇒ Base constructor

  A new instance of Base.

• #kick_start(from = Thread.current) ⇒ Object
• #request_termination(from = Thread.current) ⇒ Object

Methods included from Interface

#has_message?, #post_data_message, #post_message, #read_message, #requeue

Constructor Details

#initialize ⇒ Base

Returns a new instance of Base.

# File 'lib/fiksu-af/q_thread/base.rb', line 5

def initialize
  @queue = Queue.new
  super
end

Instance Attribute Details

#queue ⇒ Object (readonly)

Returns the value of attribute queue.

# File 'lib/fiksu-af/q_thread/base.rb', line 3

def queue
  @queue
end

Instance Method Details

#kick_start(from = Thread.current) ⇒ Object

# File 'lib/fiksu-af/q_thread/base.rb', line 16

def kick_start(from = Thread.current)
  post_data_message(:kick_start, from)
end

#request_termination(from = Thread.current) ⇒ Object

# File 'lib/fiksu-af/q_thread/base.rb', line 12

def request_termination(from = Thread.current)
  post_data_message(:terminate, from)
end