@!macro abstract_executor_service_public_api @!visibility private
# File lib/concurrent/executor/executor_service.rb, line 473 def kill synchronize do self.ns_auto_terminate = false @executor.shutdownNow nil end end
# File lib/concurrent/executor/executor_service.rb, line 447 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
# File lib/concurrent/executor/executor_service.rb, line 465 def shutdown synchronize do self.ns_auto_terminate = false @executor.shutdown nil end end
# File lib/concurrent/executor/executor_service.rb, line 456 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
# File lib/concurrent/executor/executor_service.rb, line 499 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
# File lib/concurrent/executor/executor_service.rb, line 483 def ns_running? !(ns_shuttingdown? || ns_shutdown?) end
Generated with the Darkfish Rdoc Generator 2.