MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

Rollback... Need to ensure to requests from the same alarm can execute simultaneously due to use of shared thread pool in application.

Browse Source
This commit is contained in:
Maxim Shafirov
2010-07-27 21:49:12 +04:00
parent e87e21839d
commit 4a0f00a782
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-api/src/com/intellij/util/Alarm.java
+8 -3
View File
@@ -43,6 +43,8 @@ public class Alarm implements Disposable {
private final List<Request> myRequests = new ArrayList<Request>();
private final List<Request> myPendingRequests = new ArrayList<Request>();
private final ThreadPoolExecutor myExecutorService;
private static final ThreadPoolExecutor ourSharedExecutorService = ConcurrencyUtil.newSingleThreadExecutor("Alarm pool(shared)", Thread.NORM_PRIORITY - 2);
private final Object LOCK = new Object();
@@ -53,6 +55,10 @@ public class Alarm implements Disposable {
public void dispose() {
myDisposed = true;
cancelAllRequests();
if (myThreadToUse == ThreadToUse.OWN_THREAD) {
myExecutorService.getQueue().clear();
myExecutorService.shutdown();
}
}
public enum ThreadToUse {
@@ -78,6 +84,7 @@ public class Alarm implements Disposable {
}
public Alarm(@NotNull ThreadToUse threadToUse, Disposable parentDisposable) {
myThreadToUse = threadToUse;
myExecutorService = threadToUse == ThreadToUse.OWN_THREAD ? ConcurrencyUtil.newSingleThreadExecutor("Alarm pool(own)", Thread.NORM_PRIORITY - 2) : ourSharedExecutorService;
if (parentDisposable != null) {
Disposer.register(parentDisposable, this);
@@ -236,9 +243,7 @@ public class Alarm implements Disposable {
}
}
else {
myFuture = (myThreadToUse == ThreadToUse.SHARED_THREAD)
? ourSharedExecutorService.submit(scheduledTask)
: ApplicationManager.getApplication().executeOnPooledThread(scheduledTask);
myFuture = myExecutorService.submit(scheduledTask);
}
}
}