0

我试图弄清楚如何在没有 spring 的 @scheduled 注释的情况下使用 shedlock（4.0.0 版本）。我正在如下实现 SchedulingConfigurer.configureTasks 以为我的计划方法添加触发任务。

@Component
public class EndpointSubTypeUpdateWorkerManager implements SchedulingConfigurer {
    @Autowired
    @Qualifier("priorityThreadPoolTaskExecutor")
    private TaskExecutor executor;

    @Autowired
    @Qualifier("poolScheduler")
    private TaskScheduler scheduler;

   @Autowired
    private LockProvider lockProvider;

    AtomicLong counter = new AtomicLong();

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(scheduler);
        taskRegistrar.addTriggerTask(new Runnable() {
            @Override
            public void run() {
                startWorkerThreads();
                log.debug("Running Schedular..." + Calendar.getInstance().getTime());
            }
        }, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                Calendar nextExecutionTime = new GregorianCalendar();
                Date lastActualExecutionTime = triggerContext.lastActualExecutionTime();
                nextExecutionTime.setTime(lastActualExecutionTime != null ? lastActualExecutionTime : new Date());
                nextExecutionTime.add(Calendar.MILLISECOND, getNewExecutionTime());
                return nextExecutionTime.getTime();
            }
        });
    }

    @SchedulerLock(name = "EndpointSubTypeUpdateWorkerManager_startWorkerThreads",
            lockAtLeastFor = "2M", lockAtMostFor = "14M")
    public void startWorkerThreads() {

我试图在上面的 startWorkerThreads() 方法上添加 @SchedulerLock 注释，但我在日志中看到以下调试语句

2020-05-09 18:53:48,433 [ThreadPoolTaskScheduler1] DEBUG net.javacrumbs.shedlock.spring.aop.SpringLockConfigurationExtractor - Unknown task type com.west.schoolmessenger.globaldestinationregistry.worker.EndpointSubTypeUpdateWorkerManager$1@465885e5
2020-05-09 18:53:48,433 [ThreadPoolTaskScheduler1] DEBUG net.javacrumbs.shedlock.core.DefaultLockManager - No lock configuration for com.west.schoolmessenger.globaldestinationregistry.worker.EndpointSubTypeUpdateWorkerManager$1@465885e5. Executing without lock.

我读到我可以使用下面的代码在外部调用 shedlock，但不确定如何与上面的设置集成

LockingTaskExecutor executor = new DefaultLockingTaskExecutor(lockProvider);
...
Instant lockAtMostUntil = Instant.now().plusSeconds(600);
executor.executeWithLock(runnable, new LockConfiguration("lockName", lockAtMostUntil));
4

1 回答 1

1

你可以net.javacrumbs.shedlock.spring.LockableTaskScheduler在ScheduledTaskRegistrar

于 2020-05-11T05:21:02.823 回答