import { Context } from "koishi";
import { AgentStimulus } from "../services/worldstate";
import { AgentBehaviorConfig } from "./config";
type TaskCallback = (stimulus: AgentStimulus<any>) => Promise<any>;
/**
 * @description 负责调度 Agent 刺激的处理。
 * 它管理并发、防抖以及在频道繁忙时根据策略处理新消息。
 */
export declare class StimulusScheduler {
    private readonly ctx;
    private readonly config;
    private readonly taskCallback;
    private readonly logger;
    private readonly runningTasks;
    private readonly debouncedReplyTasks;
    private readonly skippedStimulus;
    private readonly deferredTimers;
    constructor(ctx: Context, config: AgentBehaviorConfig, taskCallback: TaskCallback);
    schedule(stimulus: AgentStimulus<any>): void;
    private getDebouncedTask;
    dispose(): void;
    private handleBusyChannel;
    private handleSkippedMessagesAfterReply;
    /**
     * 设置延迟处理定时器（策略3）
     */
    private setupDeferredTimer;
}
export {};