Replaced remaining references to global task and operation thread pools.

Author: jdantonio

lib/concurrent/actor.rb

@@ -60,7 +60,7 @@ def self.root
     #   Actor.spawn name:     :ping3,
     #                 class:    AdHoc,
     #                 args:     [1]
-    #                 executor: Concurrent.configuration.global_task_pool do |add|
+    #                 executor: Concurrent.global_io_executor do |add|
     #     lambda { |number| number + add }
     #   end
     #

lib/concurrent/async.rb

@@ -198,7 +198,7 @@ def init_mutex
       serializer = Concurrent::SerializedExecution.new
 
       @__async_executor__ = Delay.new(executor: :immediate) {
-        Concurrent.configuration.global_task_pool
+        Concurrent.global_io_executor
       }
 
       @__await_delegator__ = Delay.new(executor: :immediate) {

lib/concurrent/dataflow.rb

@@ -32,7 +32,7 @@ def update(time, value, reason)
   # @raise [ArgumentError] if no block is given
   # @raise [ArgumentError] if any of the inputs are not `IVar`s
   def dataflow(*inputs, &block)
-    dataflow_with(Concurrent.configuration.global_operation_pool, *inputs, &block)
+    dataflow_with(Concurrent.global_io_executor, *inputs, &block)
   end
   module_function :dataflow
 
@@ -42,7 +42,7 @@ def dataflow_with(executor, *inputs, &block)
   module_function :dataflow_with
 
   def dataflow!(*inputs, &block)
-    dataflow_with!(Concurrent.configuration.global_task_pool, *inputs, &block)
+    dataflow_with!(Concurrent.global_io_executor, *inputs, &block)
   end
   module_function :dataflow!
 

spec/concurrent/agent_spec.rb

@@ -98,22 +98,6 @@ def trigger_observable(observable)
         agent.post { |value| 0 }
       end
 
-      it 'uses the global io executor when :executor is :task' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to \
-          receive(:global_io_executor).at_least(:once).and_return(executor)
-        agent = Agent.new(0, executor: :task)
-        agent.post { |value| 0 }
-      end
-
-      it 'uses the global fast executor when :executor is :operation' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to \
-          receive(:global_fast_executor).at_least(:once).and_return(executor)
-        agent = Agent.new(0, executor: :operation)
-        agent.post { |value| 0 }
-      end
-
       it 'uses the global io executor for #post by default' do
         expect(Concurrent).to \
           receive(:global_io_executor).at_least(:once).and_return(executor)

spec/concurrent/dataflow_spec.rb

@@ -13,7 +13,7 @@ module Concurrent
     specify '#dataflow uses the global fast executor' do
       input = Future.execute{0}
       expect(Concurrent).to receive(:dataflow_with).once.
-        with(Concurrent.global_fast_executor, input)
+        with(Concurrent.global_io_executor, input)
       Concurrent::dataflow(input){0}
     end
 

spec/concurrent/future_spec.rb

@@ -116,30 +116,6 @@ def trigger_observable(observable)
         Future.execute(executor: executor){ nil }
       end
 
-      it 'uses the global fast executor when :operation is true' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to receive(:global_fast_executor).and_return(executor)
-        Future.execute(operation: true){ nil }
-      end
-
-      it 'uses the global io executor when :task is true' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to receive(:global_io_executor).and_return(executor)
-        Future.execute(task: true){ nil }
-      end
-
-      it 'uses the global fast executor when :operation is true' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to receive(:global_fast_executor).and_return(executor)
-        Future.execute(operation: true){ nil }
-      end
-
-      it 'uses the global io executor when :task is true' do
-        warn 'deprecated syntax'
-        expect(Concurrent).to receive(:global_io_executor).and_return(executor)
-        Future.execute(task: true){ nil }
-      end
-
       it 'uses the global io executor by default' do
         expect(Concurrent).to receive(:global_io_executor).and_return(executor)
         Future.execute{ nil }