在 Spring 中使用 @Async 和 @Scheduled 时检测线程状态

Question

我正在尝试在 Spring 中实现以下要求。

我有两个正在运行的@Async 线程，我们称它们为t_A 和t_B。

t_A 使用 @Scheduled 注释设置，它需要每 30 分钟运行一次（当前设置为 5 秒）。 t_B 应该持续运行，除非 t_A 在此时启动并开始其工作 t_B 将在 x 秒内休眠并重新采样 t_A 状态，一次 t_A 工作done t_B 将继续其工作，直到 t_A 再次启动。

目前我被困在两个主要点：

1. 我不知道如何访问线程池执行器来检查线程状态

2. 使用@Scheduled 时，线程似乎永远不会完成，它似乎只是在注释中设置的固定时间休眠。

有什么想法吗？

Answer 1

由于您的争用程度较低，一个简单的ReentrantLock 应该可以完成这项工作。

首先在t_A和t_B之间创建一个共享锁：

final ReentrantLock lock = new ReentrantLock();

在能够执行他们的任务之前，t_A 和 t_B 必须获得锁，并且锁将强制在给定时间只有一个任务（t_A 或 t_B）能够执行：

t_A：

@Scheduled(...)
public void process() {
    // Acquire the lock, wait forever until the lock owner t_B release the lock
    lock.lock();
    try {
      //do the job
    } finally {
       lock.unlock();
    }
}

t_B：

while (true) {
  // try to acquire the lock, wait 500ms until the lock owner t_A release the lock
  boolean acquired = lock.tryLock(500, TimeUnit.MILLISECONDS);
  if (acquired) {
    try {
      //do the job
    } finally {
      lock.unlock();
    }
  }else{
    // t_A is already running, output a log for example
  }
}

请注意，由于您的争用较低（最多 2 个线程），因此可以使用 synchronized 简化此代码。这实际上取决于您尝试使用锁实现的目标。