class FilesToPrompt::ConcurrentProcessor

• FilesToPrompt::ConcurrentProcessor
• Reference
• Object

Overview

Handles concurrent file processing using channels and fibers

Defined in:

concurrent_processor.cr

Constructors

• .new(worker_count : Int32 = 4)

Instance Method Summary

• #completion_channel : Channel(Nil)
• #completion_channel=(completion_channel : Channel(Nil))
• #job_channel : Channel(FileJob)
• #job_channel=(job_channel : Channel(FileJob))
• #process_files_concurrently(file_jobs : Array(FileJob), app : App)

  Processes files concurrently using the worker pool

• #result_channel : Channel(FileResult)
• #result_channel=(result_channel : Channel(FileResult))
• #worker_completion_channel : Channel(Nil)
• #worker_completion_channel=(worker_completion_channel : Channel(Nil))
• #worker_count : Int32
• #worker_count=(worker_count : Int32)

Constructor Detail

Instance Method Detail