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

如何确保一个方法仅被多个线程调用一次?,第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();    }}


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zaji/5601042.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-15
下一篇 2022-12-15

发表评论

登录后才能评论

评论列表(0条)

保存