Logarithm::AsyncLogProcessor

Asynchronous log processing with worker pool.

This class provides high-throughput log processing using a pool of worker fibers to process logs concurrently. It uses channels for communication between the main thread and worker threads.

Example usage:

processor = AsyncLogProcessor.new(workers: 4)
processor.start

# Submit logs for processing
logs.each do |log|
  processor.process(log)
end

results = processor.stop