Method execute

coding-agent/src/core/executor.ts:27–55

(tasks: Task<T>[])

  }

  async execute<T>(tasks: Task<T>[]): Promise<TaskResult<T>[]> {
    // Add tasks to queue
    this.queue.push(...tasks);

    // Sort by priority (higher first)
    this.queue.sort((a, b) => b.priority - a.priority);

    // Execute tasks
    const activeTasks = new Set<Promise<void>>();

    while (this.queue.length > 0 || this.running > 0) {
      while (this.running < this.maxConcurrent && this.queue.length > 0) {
        const task = this.queue.shift()!;
        let taskPromise!: Promise<void>;
        taskPromise = this.executeTask(task).finally(() => {
          activeTasks.delete(taskPromise);
        });
        activeTasks.add(taskPromise);
      }

      // Wait for at least one task to complete
      if (activeTasks.size > 0) {
        await Promise.race(activeTasks);
      }
    }

    // Return results in original order
    return tasks.map(task => this.results.get(task.id)!);
  }

  private async executeTask<T>(task: Task<T>): Promise<void> {
    this.running++;