Vendor concurrent-ruby-1.1.4.
This commit is contained in:
		
							parent
							
								
									e3c2ad3812
								
							
						
					
					
						commit
						92fdcae23b
					
				@ -3,7 +3,7 @@ require 'rbconfig'
 | 
			
		||||
ruby_engine = defined?(RUBY_ENGINE) ? RUBY_ENGINE : 'ruby'
 | 
			
		||||
ruby_version = RbConfig::CONFIG["ruby_version"]
 | 
			
		||||
path = File.expand_path('..', __FILE__)
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/concurrent-ruby-1.1.3/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/concurrent-ruby-1.1.4/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/i18n-1.1.1/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/minitest-5.11.3/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/thread_safe-0.3.6/lib"
 | 
			
		||||
@ -21,6 +21,6 @@ $:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/powerpack-0.1.2/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/rainbow-3.0.0/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/ruby-progressbar-1.10.0/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/unicode-display_width-1.4.0/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/rubocop-0.61.0/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/rubocop-0.61.1/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/rubocop-rspec-1.30.1/lib"
 | 
			
		||||
$:.unshift "#{path}/../#{ruby_engine}/#{ruby_version}/gems/ruby-macho-2.1.0/lib"
 | 
			
		||||
 | 
			
		||||
										
											Binary file not shown.
										
									
								
							@ -20,13 +20,12 @@ if Concurrent.on_jruby?
 | 
			
		||||
 | 
			
		||||
      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)
 | 
			
		||||
        @executor.submit Job.new(args, task)
 | 
			
		||||
        true
 | 
			
		||||
      rescue Java::JavaUtilConcurrent::RejectedExecutionException
 | 
			
		||||
        raise RejectedExecutionError
 | 
			
		||||
@ -75,14 +74,6 @@ if Concurrent.on_jruby?
 | 
			
		||||
        @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)
 | 
			
		||||
@ -138,7 +138,7 @@ module Concurrent
 | 
			
		||||
        end
 | 
			
		||||
        unless name.nil?
 | 
			
		||||
          begin
 | 
			
		||||
            parent.send :remove_const, name if parent.const_defined? name
 | 
			
		||||
            parent.send :remove_const, name if parent.const_defined?(name, false)
 | 
			
		||||
            parent.const_set(name, clazz)
 | 
			
		||||
            clazz
 | 
			
		||||
          rescue NameError
 | 
			
		||||
Some files were not shown because too many files have changed in this diff Show More
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user