import { EventEmitter } from 'events'; import { ParallelJobConfig } from './types.js'; export declare class ParallelProcessor extends EventEmitter { private workers; private jobQueue; private activeJobs; private config; private workerPool; private isShuttingDown; constructor(config: ParallelJobConfig); submit(data: T, workerScript: string, priority?: 'low' | 'medium' | 'high'): Promise; submitBatch(items: T[], workerScript: string, batchSize?: number, priority?: 'low' | 'medium' | 'high'): Promise; private processNextJob; private executeJob; private handleJobError; private startJobProcessor; private generateJobId; private getPriorityValue; getStats(): { queueSize: number; activeJobs: number; availableWorkers: number; totalWorkers: number; processingRate: number; }; private calculateProcessingRate; shutdown(timeoutMs?: number): Promise; } export declare class WorkerScriptBuilder { static fileProcessor(): string; static symbolExtractor(): string; static textAnalyzer(): string; } //# sourceMappingURL=ParallelProcessor.d.ts.map