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

cleanup: avoid creating Future unnecessarily

Browse Source
This commit is contained in:
Alexey Kudravtsev
2019-03-01 15:04:05 +03:00
parent 59a4726519
commit df4bbcb608
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/com/intellij/openapi/vfs/newvfs/RefreshQueueImpl.java
+3 -3
View File
@@ -31,7 +31,7 @@ import org.jetbrains.annotations.Nullable;
import org.jetbrains.ide.PooledThreadExecutor;
import java.util.Collections;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executor;
/**
* @author max
@@ -39,7 +39,7 @@ import java.util.concurrent.ExecutorService;
public class RefreshQueueImpl extends RefreshQueue implements Disposable {
private static final Logger LOG = Logger.getInstance("#com.intellij.openapi.vfs.newvfs.RefreshQueueImpl");
private final ExecutorService myQueue = AppExecutorUtil.createBoundedApplicationPoolExecutor("RefreshQueue Pool", PooledThreadExecutor.INSTANCE, 1, this);
private final Executor myQueue = AppExecutorUtil.createBoundedApplicationPoolExecutor("RefreshQueue Pool", PooledThreadExecutor.INSTANCE, 1, this);
private final ProgressIndicator myRefreshIndicator = RefreshProgress.create(VfsBundle.message("file.synchronize.progress"));
private final TLongObjectHashMap<RefreshSession> mySessions = new TLongObjectHashMap<>();
private final FrequentEventDetector myEventCounter = new FrequentEventDetector(100, 100, FrequentEventDetector.Level.WARN);
@@ -68,7 +68,7 @@ public class RefreshQueueImpl extends RefreshQueue implements Disposable {
}
private void queueSession(@NotNull RefreshSessionImpl session, @Nullable TransactionId transaction) {
myQueue.submit(() -> {
myQueue.execute(() -> {
myRefreshIndicator.start();
try (AccessToken ignored = HeavyProcessLatch.INSTANCE.processStarted("Doing file refresh. " + session)) {
doScan(session);