Execution context cleanup

examples/09_strategy_per_stage.rb

@@ -41,7 +41,7 @@ def cleanup
     accumulator :batch, max_size: 3, to: %i[heavy_save light_log]
 
     # Heavy consumer spawns forks per batch (COW fork pattern)
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       consumer :heavy_save do |batch|
         puts "[HeavySave:process_per_batch:#{Process.pid}] Processing batch of #{batch.size}"
         sleep 0.01 # Simulate heavy work
@@ -56,7 +56,7 @@ def cleanup
     end
 
     # Light consumer uses threads (stream mode, no batching needed)
-    threads(5) do
+    thread_pool(5) do
       consumer :light_log do |batch|
         puts "[LightLog:threads] Logging batch of #{batch.size}"
         batch.each { |num| @mutex.synchronize { thread_results << num } }

examples/10_routing_to_nested_stages.rb

@@ -45,7 +45,7 @@ def cleanup
     end
 
     # Nested pipeline with forked execution
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       consumer :save do |batch|
         puts "[Consumer:save] (PID #{Process.pid}) Received batch: #{batch.inspect}"
 

examples/10_web_crawler.rb

@@ -107,7 +107,7 @@ def save_page_data(page)
     end
 
     # Stage 2: Fetch pages (with deduplication)
-    threads(20) do
+    thread_pool(20) do
       processor :fetch_pages do |page_info, output|
         url = page_info[:url]
         depth = page_info[:depth]

examples/17_database_connection_hooks.rb

@@ -75,7 +75,7 @@ def log_event(event)
     accumulator :batch, max_size: 5
 
     # Use process_per_batch to process batches
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       consumer :process_users do |batch|
         batch.each do |user_id|
           @connection_events << "Processing user #{user_id} in PID #{Process.pid}"

examples/18_resource_cleanup_hooks.rb

@@ -69,7 +69,7 @@ def cleanup
     # Accumulator batches records
     accumulator :batch, max_size: 5
 
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       # Close connections before forking
       before_fork :save_to_db do
         @resource_events << 'Closing connections before fork'

examples/19_statistics_gathering.rb

@@ -109,7 +109,7 @@ def cleanup
       @stats[:consumer_duration] = @stats[:consumer_end] - @stats[:consumer_start]
     end
 
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       before_fork :save_results do
         @stats[:forks_created] += 1
       end

examples/20_error_handling_hooks.rb

@@ -109,7 +109,7 @@ def cleanup
       @process_errors = []
     end
 
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       after_fork :save_results do
         # Report errors from this child process
         puts "Child process #{Process.pid} had #{@process_errors.size} errors" if @process_errors&.any?

examples/21_inline_hook_procs.rb

@@ -71,7 +71,7 @@ def cleanup
     accumulator :batch, max_size: 5
 
     # Inline fork hooks for consumers
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       consumer :save_data,
                before: -> { @timer[:save_start] = Time.now },
                after: -> { @timer[:save_end] = Time.now },

examples/23_runner_features.rb

@@ -36,7 +36,7 @@ def initialize
     # Use accumulator + process_per_batch to see process title in action
     accumulator :batch, max_size: 5
 
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       consumer :process do |batch|
         # On Unix systems, run 'ps aux | grep minigun' while this is running
         # You'll see: "minigun-default-consumer-12345"

examples/27_error_handling.rb

@@ -20,7 +20,7 @@ def initialize
       5.times { |i| output << i }
     end
 
-    threads(2) do
+    thread_pool(2) do
       processor :process do |item, output|
         raise StandardError, "Error on item #{item}" if item == 2
 

examples/27_execution_contexts.rb

@@ -65,7 +65,7 @@ def initialize
     end
 
     # Use thread pool for concurrent processing
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << (item * 2)
@@ -146,7 +146,7 @@ def initialize
 
       # Process isolation for CPU-bound tasks
       batch 1
-      process_per_batch(max: 2) do
+      cow_fork(2) do
         processor :process do |batch, output|
           batch.each do |item|
             output << { item: item, pid: Process.pid, result: item * 100 }
@@ -190,7 +190,7 @@ def initialize
       10.times { |i| output << i }
     end
 
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << (item * 3)
@@ -233,7 +233,7 @@ def initialize
       5.times { |i| output << i }
     end
 
-    threads(2) do
+    thread_pool(2) do
       processor :process do |item, output|
         raise StandardError, "Error on item #{item}" if item == 2
 
@@ -273,7 +273,7 @@ def initialize
       10.times { |i| output << i }
     end
 
-    threads(3) do
+    thread_pool(3) do
       processor :process do |item, output|
         output << item
       end

examples/27_parallel_execution.rb

@@ -19,7 +19,7 @@ def initialize
       10.times { |i| output << i }
     end
 
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << (item * 3)

examples/27_process_execution.rb

@@ -21,7 +21,7 @@ def initialize
 
     # Process isolation for CPU-bound tasks
     batch 1
-    process_per_batch(max: 2) do
+    cow_fork(2) do
       processor :process do |batch, output|
         batch.each do |item|
           output << { item: item, pid: Process.pid, result: item * 100 }

examples/27_termination.rb

@@ -19,7 +19,7 @@ def initialize
       10.times { |i| output << i }
     end
 
-    threads(3) do
+    thread_pool(3) do
       processor :process do |item, output|
         output << item
       end

examples/27_thread_execution.rb

@@ -20,7 +20,7 @@ def initialize
     end
 
     # Use thread pool for concurrent processing
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << (item * 2)

examples/28_basic_pool.rb

@@ -20,7 +20,7 @@ def initialize
     end
 
     # Thread pool with 3 workers
-    threads(3) do
+    thread_pool(3) do
       processor :process do |item, output|
         sleep 0.05
         output << (item * 2)

examples/28_bulk_pool.rb

@@ -19,7 +19,7 @@ def initialize
       100.times { |i| output << i }
     end
 
-    threads(20) do
+    thread_pool(20) do
       processor :process do |item, output|
         output << (item**2)
       end

examples/28_capacity_pool.rb

@@ -20,7 +20,7 @@ def initialize
     end
 
     # Limited to 2 concurrent workers
-    threads(2) do
+    thread_pool(2) do
       processor :process do |item, output|
         sleep 0.01
         output << item

examples/28_context_pool.rb

@@ -29,7 +29,7 @@ def initialize
     end
 
     # Thread pool with 3 workers
-    threads(3) do
+    thread_pool(3) do
       processor :process do |item, output|
         sleep 0.05
         output << (item * 2)
@@ -69,7 +69,7 @@ def initialize
     end
 
     # Limited to 2 concurrent workers
-    threads(2) do
+    thread_pool(2) do
       processor :process do |item, output|
         sleep 0.01
         output << item
@@ -110,7 +110,7 @@ def initialize
       50.times { |i| output << i }
     end
 
-    threads(10) do
+    thread_pool(10) do
       processor :process do |item, output|
         output << (item * 2)
       end
@@ -147,7 +147,7 @@ def initialize
       20.times { |i| output << i }
     end
 
-    threads(3) do
+    thread_pool(3) do
       processor :track do |item, output|
         @mutex.synchronize { @thread_ids << Thread.current.object_id }
         output << item
@@ -186,7 +186,7 @@ def initialize
       100.times { |i| output << i }
     end
 
-    threads(20) do
+    thread_pool(20) do
       processor :process do |item, output|
         output << (item**2)
       end
@@ -227,7 +227,7 @@ def initialize
       5.times { |i| output << i }
     end
 
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << item

examples/28_parallel_pool.rb

@@ -19,7 +19,7 @@ def initialize
       50.times { |i| output << i }
     end
 
-    threads(10) do
+    thread_pool(10) do
       processor :process do |item, output|
         output << (item * 2)
       end

examples/28_reuse_pool.rb

@@ -19,7 +19,7 @@ def initialize
       20.times { |i| output << i }
     end
 
-    threads(3) do
+    thread_pool(3) do
       processor :track do |item, output|
         @mutex.synchronize { @thread_ids << Thread.current.object_id }
         output << item

examples/28_termination_pool.rb

@@ -19,7 +19,7 @@ def initialize
       5.times { |i| output << i }
     end
 
-    threads(5) do
+    thread_pool(5) do
       processor :process do |item, output|
         sleep 0.01 # Simulate work
         output << item

examples/31_adaptive_pipeline.rb

@@ -42,15 +42,15 @@ def batch_size
       1000.times { |i| output << i }
     end
 
-    threads(thread_count) do
+    thread_pool(thread_count) do
       processor :fetch do |item, output|
         output << { id: item, data: 'fetched' }
       end
     end
 
     batch batch_size
 
-    process_per_batch(max: process_count) do
+    cow_fork(process_count) do
       processor :process do |batch, _output|
         batch.map { |x| x[:data].upcase }
       end

examples/31_configurable_downloader.rb

@@ -22,7 +22,7 @@ def initialize(threads: 10, batch_size: 100)
     end
 
     # Use instance variable for thread count
-    threads(@thread_count) do
+    thread_pool(@thread_count) do
       processor :download do |url, output|
         # Simulate download
         sleep 0.01