module Krane::Concurrency
Constants
- MAX_THREADS
Public Class Methods
split_across_threads(all_work, &block)
click to toggle source
# File lib/krane/concurrency.rb, line 6 def self.split_across_threads(all_work, &block) return if all_work.empty? raise ArgumentError, "Block of work is required" unless block_given? slice_size = ((all_work.length + MAX_THREADS - 1) / MAX_THREADS) threads = [] all_work.each_slice(slice_size) do |work_group| threads << Thread.new { work_group.each(&block) } end threads.each(&:join) end