程序包 dev.tinyflow.core.chain.runtime

类 TriggerScheduler

java.lang.Object

dev.tinyflow.core.chain.runtime.TriggerScheduler

public class TriggerScheduler
extends Object

功能: - schedule trigger (持久化到 TriggerStore 并 schedule) - cancel trigger - fire(triggerId) 用于 webhook/event/manual 主动触发 - recoverAndSchedulePending() 启动时恢复未执行的 trigger - periodical scan findDue(upto) 以保证重启/宕机后补偿触发

注意: 分布式环境下需要在 TriggerStore 层提供抢占/锁逻辑（例如 lease/owner 字段）。

嵌套类概要

嵌套类

修饰符和类型	类	说明
static interface	TriggerScheduler.TriggerConsumer

字段概要

字段

修饰符和类型	字段	说明
private final AtomicBoolean	closed
private TriggerScheduler.TriggerConsumer	consumer
private static final org.slf4j.Logger	log
private ScheduledFuture<?>	scanFuture
private final long	scanIntervalMs
private final ConcurrentMap<String,ScheduledFuture<?>>	scheduledFutures
private final ScheduledExecutorService	scheduler
private final TriggerStore	store
private final ExecutorService	worker

构造器概要

构造器

构造器	说明
TriggerScheduler(TriggerStore store, ScheduledExecutorService scheduler, ExecutorService worker, long scanIntervalMs)

方法概要

修饰符和类型	方法	说明
boolean	cancel(String triggerId)	cancel trigger (从 store 删除并尝试取消已 schedule 的 future)
boolean	fire(String triggerId)	主动触发（webhook/event/manual 场景）
private void	recoverAndSchedulePending()
void	registerConsumer(TriggerScheduler.TriggerConsumer consumer)
Trigger	schedule(Trigger trigger)	schedule a trigger: persist -> schedule (单机语义)
private void	scheduleInternal(Trigger trigger)	internal scheduling for a trigger (单机 scheduled semantics)
void	shutdown()
private void	startPeriodicScan()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

log

private static final org.slf4j.Logger log

store

private final TriggerStore store

scheduler

private final ScheduledExecutorService scheduler

worker

private final ExecutorService worker

closed

private final AtomicBoolean closed

scheduledFutures

private final ConcurrentMap<String,ScheduledFuture<?>> scheduledFutures

consumer

private volatile TriggerScheduler.TriggerConsumer consumer

scanIntervalMs

private final long scanIntervalMs

scanFuture

private ScheduledFuture<?> scanFuture

构造器详细资料

TriggerScheduler

public TriggerScheduler(TriggerStore store,
 ScheduledExecutorService scheduler,
 ExecutorService worker,
 long scanIntervalMs)

方法详细资料

registerConsumer

public void registerConsumer(TriggerScheduler.TriggerConsumer consumer)

schedule

public Trigger schedule(Trigger trigger)

schedule a trigger: persist -> schedule (单机语义)

cancel

public boolean cancel(String triggerId)

cancel trigger (从 store 删除并尝试取消已 schedule 的 future)

fire

public boolean fire(String triggerId)

主动触发（webhook/event/manual 场景）

scheduleInternal

private void scheduleInternal(Trigger trigger)

internal scheduling for a trigger (单机 scheduled semantics)

recoverAndSchedulePending

private void recoverAndSchedulePending()

startPeriodicScan

private void startPeriodicScan()

shutdown

public void shutdown()