MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-02-04 23:39:07 +07:00
Code Issues Packages Projects Releases Wiki Activity

IJPL-158348 JSRemoteModulesUsagesDetector - get rid of Disposable

Browse Source 
GitOrigin-RevId: 05ea0150241ff1fee7b857d0cdcf95a580b37123
This commit is contained in:
Vladimir Krivosheev
2024-07-27 08:44:32 +02:00
committed by intellij-monorepo-bot
parent 3f27693529
commit 6f3748266c
2 changed files with 23 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
java/compiler/impl/src/com/intellij/compiler/server/BuildManager.java
View File

@@ -1884,9 +1884,9 @@ public final class BuildManager implements Disposable {
}
private abstract class BuildManagerPeriodicTask implements Runnable {
private final Alarm myAlarm;
private final Alarm alarm;
private final AtomicBoolean myInProgress = new AtomicBoolean(false);
private final Runnable myTaskRunnable = () -> {
private final Runnable taskRunnable = () -> {
try {
runTask();
}
@@ -1895,8 +1895,11 @@ public final class BuildManager implements Disposable {
}
};
private final @NotNull CoroutineScope coroutineScope;
BuildManagerPeriodicTask(@NotNull CoroutineScope coroutineScope) {
myAlarm = new Alarm(coroutineScope, Alarm.ThreadToUse.POOLED_THREAD);
this.coroutineScope = coroutineScope;
alarm = new Alarm(coroutineScope, Alarm.ThreadToUse.POOLED_THREAD);
}
final void schedule() {
@@ -1905,11 +1908,11 @@ public final class BuildManager implements Disposable {
private void schedule(boolean increasedDelay) {
cancelPendingExecution();
myAlarm.addRequest(this, Math.max(100, increasedDelay ? 10 * getDelay() : getDelay()));
alarm.addRequest(this, Math.max(100, increasedDelay ? 10 * getDelay() : getDelay()));
}
void cancelPendingExecution() {
myAlarm.cancelAllRequests();
alarm.cancelAllRequests();
}
protected boolean shouldPostpone() {
@@ -1925,7 +1928,7 @@ public final class BuildManager implements Disposable {
final boolean shouldPostponeAllTasks = HeavyProcessLatch.INSTANCE.isRunning() || mySuspendBackgroundTasksCounter.get() > 0;
if (!shouldPostponeAllTasks && !shouldPostpone() && !myInProgress.getAndSet(true)) {
try {
AppJavaExecutorUtil.executeOnPooledIoThread(myTaskRunnable);
AppJavaExecutorUtil.executeOnPooledIoThread(coroutineScope, taskRunnable);
}
catch (CancellationException ignored) {
// we were shut down