如何在 SpringBoot 中以线程安全的方式执行 @Scheduled 作业？

如何解决如何在 SpringBoot 中以线程安全的方式执行 @Scheduled 作业？

我有一个将元素添加到集合的服务类，并且有一个计划作业方法每 2 秒执行一次，它读取添加到集合中的所有元素（服务在其中添加元素的元素），并在最后，它清除了整个集合。

如果某些元素在我从集合中读取数据之间或在我从集合中读取数据之后和清除集合之前的时间之间被添加到列表中，那么我会感到困惑，那么该元素将丢失。

>

如何确保在预定作业未完成时没有任何元素添加到集合中？

EventService.java

public void foo(){
    eventSet.add(new Event("event description"));
}

EventJob.java

@Autowired
EventService eventService;

@Scheduled(cron = "${cron.expression.for.every.2.second}")
private void job(){
    for(Event event : eventService.getEventSet()){
         //process event
         System.out.println(event);
    }
    eventService.getEventSet().clear();
}

解决方法

据我所知，您可以为此行为创建一个线程控件，

private static ReentrantLock listLock = new ReentrantLock();

  private void readSomeData() {
    // Get the lock of object
    listLock.lock();

    // read list

    // free the lock
    listLock.unlock();
  }

  @Scheduled(cron = "${cron.expression.for.every.2.second}")
  private void job() {
    // Check lock is free or not
    if (!listLock.isLocked()) {
      // Get the lock of object
      listLock.lock();
      for (Event event : eventService.getEventSet()) {
        // process event
        System.out.println(event);
      }
      eventService.getEventSet().clear();
    }
    // free the lock
    listLock.unlock();
  }

,

您应该意识到，如果您处于多机集群中，则会出现其他问题，而这种“内存中”解决方案无法解决这些问题。

private AtomicBoolean isRunning = new AtomicBoolean(false);

public void job(){
     Set<YourObject> events = eventService.getEventSet();
     if (isRunning.compareAndSet(false,true)) {
        for(Event event : events){
            //process event
        }
       
        eventService.getEventSet().clear();
        isRunning.compareAndSet(true,false);
     }
     
}

在 op 澄清后编辑！

,

如果您不想在运行计划作业时被添加到集合中，则意味着您必须根据某些设置的限制维护一些标志，并在达到限制“false”时启用该 AtomicBoolean 为 true已经清除了集合。 下面是伪代码，

AtomicBoolean canAddData = new AtomicBoolean(true);

public void foo(){
    if(canAddData){ // here instead of atomicboolean you can use eventSet.size()==10 as well if you want to be added based on some level size.
      eventSet.add(new Event("event description"));
      canAddData.set(eventSet.size() <= 10)
   }
}

// scheduler code 
public void processEvents() {
     Iterator<Event> eventIter = eventSet.iterator()
     while(eventIterator.hasNext()) {
          Event = eventIterator.remove()
          // Process event here and clearing item one by one
     }
     canAddData.set(true)
}