Implemented more specs.

Author: jdantonio

lib/concurrent/java_cached_thread_pool.rb

@@ -37,6 +37,7 @@ def initialize(opts = {})
           java.util.concurrent.SynchronousQueue.new,
           OVERFLOW_POLICIES[@overflow_policy].new)
 
+        # without this the process may fail to exit
         at_exit { self.kill }
       end
     end

lib/concurrent/java_fixed_thread_pool.rb

@@ -29,6 +29,7 @@ def initialize(num_threads, opts = {})
           java.util.concurrent.LinkedBlockingQueue.new,
           OVERFLOW_POLICIES[@overflow_policy].new)
 
+        # without this the process may fail to exit
         at_exit { self.kill }
       end
     end

lib/concurrent/java_thread_pool_executor.rb

@@ -61,6 +61,7 @@ def initialize(opts = {})
           idletime, java.util.concurrent.TimeUnit::SECONDS,
           queue, OVERFLOW_POLICIES[@overflow_policy].new)
 
+        # without this the process may fail to exit
         at_exit { self.kill }
       end
 

spec/concurrent/configuration_spec.rb

@@ -4,12 +4,18 @@ module Concurrent
 
   describe 'module functions' do
 
-    context '#task' do
-      pending
+    let(:executor){ ImmediateExecutor.new }
+
+    specify '#task posts to the global task pool' do
+      Concurrent.configuration.should_receive(:global_task_pool).and_return(executor)
+      executor.should_receive(:post).with(1, 2, 3)
+      Concurrent::task(1, 2, 3){|a, b, c| nil }
     end
 
-    context '#operation' do
-      pending
+    specify '#operation posts to the global operation pool' do
+      Concurrent.configuration.should_receive(:global_operation_pool).and_return(executor)
+      executor.should_receive(:post).with(1, 2, 3)
+      Concurrent::operation(1, 2, 3){|a, b, c| nil }
     end
   end
 

spec/concurrent/java_cached_thread_pool_spec.rb

@@ -17,8 +17,6 @@ module Concurrent
 
       it_should_behave_like :cached_thread_pool
 
-      it 'defines an #at_exit shutdown hook'
-
       context '#initialize' do
 
         it 'sets :min_length correctly' do

spec/concurrent/java_fixed_thread_pool_spec.rb

@@ -17,8 +17,6 @@ module Concurrent
 
       it_should_behave_like :fixed_thread_pool
 
-      it 'defines an #at_exit shutdown hook'
-
       context '#initialize' do
 
         it 'sets :min_length correctly' do

spec/concurrent/java_thread_pool_executor_spec.rb

@@ -25,8 +25,6 @@ module Concurrent
 
       it_should_behave_like :thread_pool_executor
 
-      it 'defines an #at_exit shutdown hook'
-
       context '#overload_policy' do
 
         specify ':abort maps to AbortPolicy' do