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

[file-history] extract RefreshRequest class

Browse Source
This commit is contained in:
Julia Beliaeva
2018-07-09 17:35:14 +03:00
parent be0beffd12
commit 5cadb8839c
1 changed files with 39 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/vcs-impl/src/com/intellij/openapi/vcs/history/FileHistoryRefresher.java
+39 -26
View File
@@ -15,6 +15,7 @@
*/
package com.intellij.openapi.vcs.history;
import com.intellij.openapi.Disposable;
import com.intellij.openapi.application.ApplicationManager;
import com.intellij.openapi.vcs.AbstractVcs;
import com.intellij.openapi.vcs.FilePath;
@@ -66,32 +67,8 @@ public class FileHistoryRefresher implements FileHistoryRefresherI {
myStartingRevisionNumber = startingRevisionNumber;
mySessionPartner = new FileHistorySessionPartner(vcsHistoryProvider, path, startingRevisionNumber, vcs, this);
int delayMillis = 20_000;
Alarm updateAlarm = new Alarm(Alarm.ThreadToUse.SWING_THREAD, mySessionPartner);
updateAlarm.addRequest(new Runnable() {
Future<?> lastTask;
public void run() {
if (lastTask != null) {
lastTask.cancel(false);
}
if (myVcs.getProject().isDisposed()) {
return;
}
updateAlarm.cancelAllRequests();
if (updateAlarm.isDisposed()) return;
updateAlarm.addRequest(this, delayMillis);
if (!ApplicationManager.getApplication().isActive()) return;
lastTask = ourExecutor.submit(() -> {
if (!updateAlarm.isDisposed() && mySessionPartner.shouldBeRefreshed()) {
ApplicationManager.getApplication().invokeLater(() -> refresh(true));
}
});
}
}, delayMillis);
RefreshRequest request = new RefreshRequest(20_000, mySessionPartner);
request.schedule();
}
@NotNull
@@ -146,4 +123,40 @@ public class FileHistoryRefresher implements FileHistoryRefresherI {
myFirstTime = false;
}
private class RefreshRequest implements Runnable {
@NotNull private final Alarm myUpdateAlarm;
private final int myDelayMillis;
@Nullable Future<?> myLastTask;
public RefreshRequest(int delayMillis, @NotNull Disposable parent) {
myUpdateAlarm = new Alarm(Alarm.ThreadToUse.SWING_THREAD, parent);
myDelayMillis = delayMillis;
}
public void run() {
if (myLastTask != null) {
myLastTask.cancel(false);
}
if (myVcs.getProject().isDisposed()) {
return;
}
myUpdateAlarm.cancelAllRequests();
if (myUpdateAlarm.isDisposed()) return;
schedule();
if (!ApplicationManager.getApplication().isActive()) return;
myLastTask = ourExecutor.submit(() -> {
if (!myUpdateAlarm.isDisposed() && mySessionPartner.shouldBeRefreshed()) {
ApplicationManager.getApplication().invokeLater(() -> refresh(true));
}
});
}
public void schedule() {
myUpdateAlarm.addRequest(this, myDelayMillis);
}
}
}