Gecko [ lorencats.com ]

Name	Size	Permission
abstract_executor_service.rb	3.29 KB	-rw-r--r--
cached_thread_pool.rb	2.58 KB	-rw-r--r--
executor_service.rb	5.65 KB	-rw-r--r--
fixed_thread_pool.rb	9.57 KB	-rw-r--r--
immediate_executor.rb	1.8 KB	-rw-r--r--
indirect_immediate_executor.rb	1.54 KB	-rw-r--r--
java_executor_service.rb	2.5 KB	-rw-r--r--
java_single_thread_executor.rb	919 B	-rw-r--r--
java_thread_pool_executor.rb	3.99 KB	-rw-r--r--
ruby_executor_service.rb	1.49 KB	-rw-r--r--
ruby_single_thread_executor.rb	607 B	-rw-r--r--
ruby_thread_pool_executor.rb	9.98 KB	-rw-r--r--
safe_task_executor.rb	1.01 KB	-rw-r--r--
serial_executor_service.rb	991 B	-rw-r--r--
serialized_execution.rb	2.73 KB	-rw-r--r--
serialized_execution_delegator...	859 B	-rw-r--r--
simple_executor_service.rb	2.57 KB	-rw-r--r--
single_thread_executor.rb	2.47 KB	-rw-r--r--
thread_pool_executor.rb	4.19 KB	-rw-r--r--
timer_set.rb	5.92 KB	-rw-r--r--

Code Editor : java_executor_service.rb

if Concurrent.on_jruby?

require 'concurrent/errors'
  require 'concurrent/utility/engine'
  require 'concurrent/executor/abstract_executor_service'

module Concurrent

# @!macro abstract_executor_service_public_api
    # @!visibility private
    class JavaExecutorService < AbstractExecutorService
      java_import 'java.lang.Runnable'

FALLBACK_POLICY_CLASSES = {
        abort:       java.util.concurrent.ThreadPoolExecutor::AbortPolicy,
        discard:     java.util.concurrent.ThreadPoolExecutor::DiscardPolicy,
        caller_runs: java.util.concurrent.ThreadPoolExecutor::CallerRunsPolicy
      }.freeze
      private_constant :FALLBACK_POLICY_CLASSES

def initialize(*args, &block)
        super
        ns_make_executor_runnable
      end

def post(*args, &task)
        raise ArgumentError.new('no block given') unless block_given?
        return handle_fallback(*args, &task) unless running?
        @executor.submit_runnable Job.new(args, task)
        true
      rescue Java::JavaUtilConcurrent::RejectedExecutionException
        raise RejectedExecutionError
      end

def wait_for_termination(timeout = nil)
        if timeout.nil?
          ok = @executor.awaitTermination(60, java.util.concurrent.TimeUnit::SECONDS) until ok
          true
        else
          @executor.awaitTermination(1000 * timeout, java.util.concurrent.TimeUnit::MILLISECONDS)
        end
      end

def shutdown
        synchronize do
          self.ns_auto_terminate = false
          @executor.shutdown
          nil
        end
      end

def kill
        synchronize do
          self.ns_auto_terminate = false
          @executor.shutdownNow
          nil
        end
      end

private

def ns_running?
        !(ns_shuttingdown? || ns_shutdown?)
      end

def ns_shuttingdown?
        if @executor.respond_to? :isTerminating
          @executor.isTerminating
        else
          false
        end
      end

def ns_shutdown?
        @executor.isShutdown || @executor.isTerminated
      end

def ns_make_executor_runnable
        if !defined?(@executor.submit_runnable)
          @executor.class.class_eval do
            java_alias :submit_runnable, :submit, [java.lang.Runnable.java_class]
          end
        end
      end

class Job
        include Runnable
        def initialize(args, block)
          @args = args
          @block = block
        end

def run
          @block.call(*@args)
        end
      end
      private_constant :Job
    end
  end
end

${this.title}

Code Editor : java_executor_service.rb