/**
 * 🔧 Parallel Queue Adapter
 *
 * Adapter for parallel queue processing with worker management.
 * Supports concurrent processing with configurable worker limits.
 */
import { QueueAdapter } from '../queue-adapter';
import { QueueConfig, QueueStatistics, QueueProcessor, QueueResult, QueueEventCallbacks } from '../types';
export declare class ParallelQueueAdapter<T = any> extends QueueAdapter<T> {
    private processingQueue;
    private workers;
    private isPaused;
    private processingPromise?;
    private backpressureController?;
    private resourceMonitor?;
    constructor(config: QueueConfig, callbacks?: QueueEventCallbacks<T>);
    /**
     * Setup backpressure controller
     */
    private setupBackpressure;
    /**
     * Setup resource monitoring
     */
    private setupResourceMonitoring;
    enqueue(data: T[], options?: {
        priority?: number;
    }): string[];
    process(processor: QueueProcessor<T>): Promise<QueueResult<T>>;
    getStatistics(): QueueStatistics;
    pause(): void;
    resume(): void;
    clear(): void;
    configure(config: Partial<QueueConfig>): void;
    /**
     * Initialize worker pool
     */
    private initializeWorkers;
    /**
     * Reset all workers
     */
    private resetWorkers;
    /**
     * Get next pending item from queue
     */
    private getNextItem;
    /**
     * Run individual worker
     */
    private runWorker;
    /**
     * Create timeout promise
     */
    private createTimeoutPromise;
    /**
     * Simple delay utility
     */
    private delay;
    /**
     * Get worker information
     */
    getWorkerInfo(): Array<{
        id: string;
        isActive: boolean;
        currentItem?: string;
    }>;
    /**
     * Get active worker count
     */
    getActiveWorkerCount(): number;
}
//# sourceMappingURL=parallel-queue-adapter.d.ts.map