Sha256: e2c3d2383fdabae7edfe36661cf0199bcc8e63fde27420edbac65e496784d7d9

Contents?: true

Size: 373 Bytes

Versions: 7

Compression:

Stored size: 373 Bytes

Contents

module Af::QThread
  class Base < Thread
    attr_reader :queue

    def initialize
      @queue = Queue.new
      super
    end

    include ::Af::QThread::Interface

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

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

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
fiksu-af-1.1.6 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.5 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.4 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.3 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.2 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.1 lib/fiksu-af/q_thread/base.rb
fiksu-af-1.1.0 lib/fiksu-af/q_thread/base.rb