export type LaneTaskState = "queued" | "running" | "completed" | "failed" | "cancelled";
export interface LaneTask<T = unknown> {
    turnId: string;
    run(signal: AbortSignal): Promise<T>;
}
export interface LaneTaskResult<T = unknown> {
    turnId: string;
    state: Exclude<LaneTaskState, "queued" | "running">;
    value?: T;
    error?: unknown;
}
export declare class AgentLane {
    #private;
    readonly actorId: string;
    constructor(input: {
        actorId: string;
        maxQueued: number;
        onState?: (turnId: string, state: LaneTaskState) => void;
    });
    get queued(): number;
    get activeTurnId(): string | undefined;
    enqueue<T>(task: LaneTask<T>): Promise<LaneTaskResult<T>>;
    cancel(turnId: string): boolean;
    close(): void;
}
export declare class Dispatcher {
    #private;
    constructor(input: {
        maxQueuedPerAgent: number;
        onState?: (actorId: string, turnId: string, state: LaneTaskState) => void;
    });
    enqueue<T>(actorId: string, task: LaneTask<T>): Promise<LaneTaskResult<T>>;
    cancel(actorId: string, turnId: string): boolean;
    stats(): Array<{
        actorId: string;
        queued: number;
        activeTurnId?: string;
    }>;
    close(): void;
}
//# sourceMappingURL=dispatcher.d.ts.map