export interface Task<T> {
    id: string;
    metadata?: Record<string, unknown>;
    run: (context: TaskExecutionContext) => Promise<T>;
}
export interface TaskExecutionContext {
    signal: AbortSignal;
}
export interface TaskResult<T> {
    taskId: string;
    success: boolean;
    value?: T;
    error?: Error;
    durationMs: number;
    startedAt: number;
    finishedAt: number;
    metadata?: Record<string, unknown>;
    aborted?: boolean;
}
export interface TaskCallbacks<T> {
    onTaskStart?: (task: Task<T>) => void | Promise<void>;
    onTaskComplete?: (result: TaskResult<T>) => void | Promise<void>;
    onError?: (task: Task<T>, error: Error, durationMs: number) => void | Promise<void>;
}
export interface ParallelRunnerOptions<T = unknown> {
    maxConcurrency?: number;
    timeoutMs?: number;
    failFast?: boolean;
    callbacks?: TaskCallbacks<T>;
    evaluateTaskSuccess?: (value: T, task: Task<T>) => boolean;
}
export interface ParallelRunnerMetrics {
    totalTasks: number;
    startedTasks: number;
    completedTasks: number;
    successCount: number;
    failureCount: number;
    totalDurationMs: number;
    averageDurationMs: number;
    throughput: number;
}