import { CommitID, StreamID } from '@dustil/streamid';
import { DiagnosticsLogger } from '@dustil/common';
import { TaskQueueLike } from '../pubsub/task-queue.js';
export declare class ExecutionQueue {
    private readonly name;
    private readonly concurrencyLimit;
    private readonly logger;
    private readonly tasks;
    private readonly semaphore;
    constructor(name: string, concurrencyLimit: number, logger: DiagnosticsLogger);
    forStream(streamId: StreamID | CommitID): TaskQueueLike;
    onIdle(): Promise<void>;
    pause(): void;
    close(): Promise<void>;
}
//# sourceMappingURL=execution-queue.d.ts.map