java 线程只执行一次_java – 如何确保方法只执行一次并且只从一个线程执行?...
@ ShayHaned的解決方案使用鎖定.您可以通過AtomicBoolean使其更高效,如:
AtomicBoolean wasRun = new AtomicBoolean(false);
CountDownLatch initCompleteLatch = new CountDownLatch(1);
public void initialize() {
if (!wasRun.getAndSet(true)) {
List metadata = getMetadata(true);
List process = getProcess();
if (!metadata.isEmpty() && !process.isEmpty()) {
Manager.setAllMetadata(metadata, process);
}
startBackgroundThread();
initCompleteLatch.countDown();
} else {
log.info("Waiting to ensure initialize is done.");
initCompleteLatch.await();
log.warn("I was already run");
}
}
以上假設您不必等待startBackgroundThread中的工作完成.如果你這樣做,解決方案就變成:
AtomicBoolean wasRun = new AtomicBoolean(false);
CountDownLatch initCompleteLatch = new CountDownLatch(1);
public void initialize() {
if (!wasRun.getAndSet(true)) {
List metadata = getMetadata(true);
List process = getProcess();
if (!metadata.isEmpty() && !process.isEmpty()) {
Manager.setAllMetadata(metadata, process);
}
// Pass the latch to startBackgroundThread so it can
// call countDown on it when it's done.
startBackgroundThread(initCompleteLatch);
} else {
log.info("Waiting to ensure initialize is done.");
initCompleteLatch.await();
log.warn("I was already run");
}
}
這樣做的原因是AtomicBoolean.getAndSet(true)將在一個原子操作中返回先前設置的值并使新值為true.因此,獲取方法的第一個線程將返回false(因為變量初始化為false),并且原子地將其設置為true.由于第一個線程返回false,它將在if語句中獲取第一個分支,并且您的初始化將會發生.任何其他調用都會發現wasRun.getAndSet返回true,因為第一個線程將其設置為true,因此它們將獲取第二個分支,您將獲得所需的日志消息.
CountDownLatch初始化為1,因此除第一次調用之外的所有線程都在等待它.它們將阻塞,直到第一個線程調用countDown,這將把計數設置為0,釋放所有等待的線程.
總結
以上是生活随笔為你收集整理的java 线程只执行一次_java – 如何确保方法只执行一次并且只从一个线程执行?...的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 本地服务器的音乐如何才能播放视频文件夹,
- 下一篇: html高度随宽度编号,纯css实现容器