/** * Parallel Execution Module * * Unified exports for all parallel execution capabilities in AGI Core. * Provides automatic parallel task management with dependency resolution, * agent worker pools, and integration with orchestration pipelines. * * Principal Investigator: Bo Shang * Framework: agi-cli */ export { ParallelExecutor, WorkerPool, createParallelExecutor, createTask, executeParallel, mapParallel, type ParallelTask, type TaskResult, type BatchResult, type ParallelExecutorConfig, type TaskEvent, type TaskStatus, type ExecutionPlan, type WorkerConfig, type WorkItem, type WorkerPoolConfig, } from './parallelExecutor.js'; export { ConcurrencyPool, RateLimiter, TTLCache, parallelMap, throttle, debounce, memoize, sleep, withTimeout, retry, type ConcurrencyConfig, type RateLimiterConfig, type ThrottleConfig, type CacheConfig, } from '../utils/asyncUtils.js'; export { AgentWorkerPool, createAgentWorkerPool, createAgentTask, type AgentTask, type AgentWorkerConfig, type AgentWorkerPoolConfig, type PoolEvent, type PoolStats, type WorkerInfo, type WorkerStatus, type BalanceStrategy, type TaskResult as AgentTaskResult, } from '../runtime/agentWorkerPool.js'; export { RepoUpgradeOrchestrator, buildRepoWidePlan, type RepoUpgradeMode, type RepoUpgradePlan, type RepoUpgradeModule, type RepoUpgradeStep, type RepoUpgradeReport, type RepoUpgradeRunOptions, type UpgradeVariant, type UpgradeStepResult, type UpgradeModuleReport, type UpgradeStepOutcome, type ValidationRunResult, type VariantWinStats, REPO_UPGRADE_MODE_DEFINITIONS, } from './repoUpgradeOrchestrator.js'; /** * Configuration presets for common parallel execution scenarios */ export declare const ParallelPresets: { /** * Light parallel execution - suitable for I/O-bound tasks * Lower concurrency, minimal resource usage */ readonly light: { readonly maxConcurrency: 3; readonly defaultTimeout: number; readonly continueOnFailure: true; readonly autoDetectParallel: true; }; /** * Standard parallel execution - balanced for most use cases * Moderate concurrency, suitable for typical workflows */ readonly standard: { readonly maxConcurrency: 5; readonly defaultTimeout: number; readonly continueOnFailure: true; readonly autoDetectParallel: true; }; /** * Heavy parallel execution - suitable for CPU-bound tasks * Higher concurrency, aggressive parallelization */ readonly heavy: { readonly maxConcurrency: 8; readonly defaultTimeout: number; readonly continueOnFailure: true; readonly autoDetectParallel: true; }; /** * Strict sequential execution - no parallelization * For workflows that require guaranteed ordering */ readonly sequential: { readonly maxConcurrency: 1; readonly defaultTimeout: number; readonly continueOnFailure: false; readonly autoDetectParallel: false; }; /** * Agent pool configuration for multi-agent scenarios */ readonly agentPool: { readonly balanceStrategy: "least-busy"; readonly defaultTimeout: number; readonly maxQueueSize: 50; }; }; /** * Quick parallel map with sensible defaults */ export declare function quickParallelMap(items: T[], fn: (item: T) => Promise): Promise; /** * Execute a batch of async functions in parallel with concurrency limit */ export declare function batchExecute(tasks: Array<() => Promise>, concurrency?: number): Promise; /** * Create a simple task queue for sequential execution */ export declare function createTaskQueue(): { add(task: () => Promise): void; process(): Promise; readonly length: number; readonly isProcessing: boolean; }; //# sourceMappingURL=parallel.d.ts.map