Contents

# frozen_string_literal: true

module ActiveConcurrency
  module Threads
    class Worker < ActiveConcurrency::Base::Worker

      def initialize(name: nil)
        super(name: name)
        @thread = Thread.new(@name) { perform }
      end

      def exit!
        @thread.exit
      end

      def join
        @thread.join
      end

      def status
        @thread.status
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
active_concurrency-0.1.0	lib/active_concurrency/threads/worker.rb