如何确保一个方法仅被多个线程调用一次？

Question

我有以下结构：

public void someMethod(){  
   //DO SOME STUFF
   try{  
    doSomeProcessing();  
   }  
   catch (Exception e){  
        loadSomeHeavyData();  
        doSomeProcessing();      
   }    
}

该方法someMethod 可以 被许多线程同时调用。该doSomeProcessing 会
抛出异常（它在后台，可能成为过时的使用一些数据）。
如果引发异常，则loadSomeHeavyData();执行一些耗时的任务，比如说“更新”所有当前数据，并且我可以调用doSomeProcessing();。
问题： 如何确保loadSomeHeavyData();只调用 一次
？如果我在的条目中放置了原子标志，loadSomeHeavyData();则不能确定何时清除该标志。
我该如何解决？请注意：doSomeProcessing();由于它是一个外部API，因此我无法修改，并且我正在使用装饰器模式来使用它。

Answer 1

您的loadSomeHeavyData方法可以使用阻塞机制使所有线程等待更新完成，但是实际上只能让其中一个执行更新：

private final AtomicBoolean updateStarted = new AtomicBoolean();
private final CountDownLatch updateFinished = new CountDownLatch(1);

public void loadSomeHeavyData() {
    if (updateStarted.compareAndSet(false, true)) {
        //do the loading
        updateFinished.countDown();
    } else {
        //update already running, wait
        updateFinished.await();
    }
}

注意我的假设：

• 您希望所有线程都等到加载完成后才能doSomeProcessing再次调用更新的数据
• 您只需调用loadSomeHeavyData一次-否则，您将需要重置标志和CountdownLatch（这可能不是最合适的机制）。

编辑

您最近的评论表明您实际上想loadSomeHeavyData多次拨打电话，一次最多拨打 一次 。

private final Semaphore updatePermit = new Semaphore(1);

public void loadSomeHeavyData() {
    if (updatePermit.tryAcquire()) {
        //do the loading and release updatePermit when done
        updatePermit.release();
    } else {
        //update already running, wait
        updatePermit.acquire();
        //release the permit immediately
        updatePermit.release();
    }
}