Runnable: replace anonymous class with lambda

In Java 8 Runnable is functional interface and can be replaced with
lambda expressions or method references.

Change-Id: I2896b39c27b2e5a91a60149155a8c00a8eb48e39
This commit is contained in:
David Ostrovsky
2017-03-26 13:03:21 +02:00
committed by Shawn Pearce
parent 8f0528f3b5
commit 8785d73fa5
30 changed files with 493 additions and 799 deletions

View File

@@ -133,18 +133,15 @@ public class GerritServer {
static GerritServer start(Description desc, Config baseConfig) throws Exception { static GerritServer start(Description desc, Config baseConfig) throws Exception {
Config cfg = desc.buildConfig(baseConfig); Config cfg = desc.buildConfig(baseConfig);
Logger.getLogger("com.google.gerrit").setLevel(Level.DEBUG); Logger.getLogger("com.google.gerrit").setLevel(Level.DEBUG);
final CyclicBarrier serverStarted = new CyclicBarrier(2); CyclicBarrier serverStarted = new CyclicBarrier(2);
final Daemon daemon = Daemon daemon =
new Daemon( new Daemon(
new Runnable() { () -> {
@Override
public void run() {
try { try {
serverStarted.await(); serverStarted.await();
} catch (InterruptedException | BrokenBarrierException e) { } catch (InterruptedException | BrokenBarrierException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
}
}, },
Paths.get(baseConfig.getString("gerrit", null, "tempSiteDir"))); Paths.get(baseConfig.getString("gerrit", null, "tempSiteDir")));
daemon.setEmailModuleForTesting(new FakeEmailSender.Module()); daemon.setEmailModuleForTesting(new FakeEmailSender.Module());

View File

@@ -79,13 +79,10 @@ abstract class ChunkManager {
cm.addLineClass(line, where, className); cm.addLineClass(line, where, className);
} }
undo.add( undo.add(
new Runnable() { () -> {
@Override
public void run() {
for (int line = start; line < end; line++) { for (int line = start; line < end; line++) {
cm.removeLineClass(line, where, className); cm.removeLineClass(line, where, className);
} }
}
}); });
} }
} }

View File

@@ -203,33 +203,27 @@ abstract class CommentManager {
abstract String getTokenSuffixForActiveLine(CodeMirror cm); abstract String getTokenSuffixForActiveLine(CodeMirror cm);
Runnable signInCallback(final CodeMirror cm) { Runnable signInCallback(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
String token = host.getToken(); String token = host.getToken();
if (cm.extras().hasActiveLine()) { if (cm.extras().hasActiveLine()) {
token += "@" + getTokenSuffixForActiveLine(cm); token += "@" + getTokenSuffixForActiveLine(cm);
} }
Gerrit.doSignIn(token); Gerrit.doSignIn(token);
}
}; };
} }
abstract void newDraft(CodeMirror cm); abstract void newDraft(CodeMirror cm);
Runnable newDraftCallback(final CodeMirror cm) { Runnable newDraftCallback(CodeMirror cm) {
if (!Gerrit.isSignedIn()) { if (!Gerrit.isSignedIn()) {
return signInCallback(cm); return signInCallback(cm);
} }
return new Runnable() { return () -> {
@Override
public void run() {
if (cm.extras().hasActiveLine()) { if (cm.extras().hasActiveLine()) {
newDraft(cm); newDraft(cm);
} }
}
}; };
} }
@@ -268,9 +262,7 @@ abstract class CommentManager {
abstract SortedMap<Integer, CommentGroup> getMapForNav(DisplaySide side); abstract SortedMap<Integer, CommentGroup> getMapForNav(DisplaySide side);
Runnable commentNav(final CodeMirror src, final Direction dir) { Runnable commentNav(final CodeMirror src, final Direction dir) {
return new Runnable() { return () -> {
@Override
public void run() {
// Every comment appears in both side maps as a linked pair. // Every comment appears in both side maps as a linked pair.
// It is only necessary to search one side to find a comment // It is only necessary to search one side to find a comment
// on either side of the editor pair. // on either side of the editor pair.
@@ -312,7 +304,6 @@ abstract class CommentManager {
cm.setCursor(Pos.create(g.getLine() - 1)); cm.setCursor(Pos.create(g.getLine() - 1));
cm.scrollToY(y - 0.5 * cm.scrollbarV().getClientHeight()); cm.scrollToY(y - 0.5 * cm.scrollbarV().getClientHeight());
cm.focus(); cm.focus();
}
}; };
} }
@@ -425,27 +416,21 @@ abstract class CommentManager {
abstract CommentGroup getCommentGroupOnActiveLine(CodeMirror cm); abstract CommentGroup getCommentGroupOnActiveLine(CodeMirror cm);
Runnable toggleOpenBox(final CodeMirror cm) { Runnable toggleOpenBox(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
CommentGroup group = getCommentGroupOnActiveLine(cm); CommentGroup group = getCommentGroupOnActiveLine(cm);
if (group != null) { if (group != null) {
group.openCloseLast(); group.openCloseLast();
} }
}
}; };
} }
Runnable openCloseAll(final CodeMirror cm) { Runnable openCloseAll(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
CommentGroup group = getCommentGroupOnActiveLine(cm); CommentGroup group = getCommentGroupOnActiveLine(cm);
if (group != null) { if (group != null) {
group.openCloseAll(); group.openCloseAll();
} }
}
}; };
} }

View File

@@ -336,7 +336,7 @@ abstract class DiffScreen extends Screen {
handlers.clear(); handlers.clear();
} }
void registerCmEvents(final CodeMirror cm) { void registerCmEvents(CodeMirror cm) {
cm.on("cursorActivity", updateActiveLine(cm)); cm.on("cursorActivity", updateActiveLine(cm));
cm.on("focus", updateActiveLine(cm)); cm.on("focus", updateActiveLine(cm));
KeyMap keyMap = KeyMap keyMap =
@@ -356,9 +356,7 @@ abstract class DiffScreen extends Screen {
.on("Shift-O", getCommentManager().openCloseAll(cm)) .on("Shift-O", getCommentManager().openCloseAll(cm))
.on( .on(
"I", "I",
new Runnable() { () -> {
@Override
public void run() {
switch (getIntraLineStatus()) { switch (getIntraLineStatus()) {
case OFF: case OFF:
case OK: case OK:
@@ -369,156 +367,97 @@ abstract class DiffScreen extends Screen {
default: default:
break; break;
} }
}
})
.on(
"','",
new Runnable() {
@Override
public void run() {
prefsAction.show();
}
}) })
.on("','", prefsAction::show)
.on( .on(
"Shift-/", "Shift-/",
new Runnable() { () -> {
@Override
public void run() {
new ShowHelpCommand().onKeyPress(null); new ShowHelpCommand().onKeyPress(null);
}
}) })
.on( .on(
"Space", "Space",
new Runnable() { () -> {
@Override
public void run() {
cm.vim().handleKey("<C-d>"); cm.vim().handleKey("<C-d>");
}
}) })
.on( .on(
"Shift-Space", "Shift-Space",
new Runnable() { () -> {
@Override
public void run() {
cm.vim().handleKey("<C-u>"); cm.vim().handleKey("<C-u>");
}
}) })
.on( .on(
"Ctrl-F", "Ctrl-F",
new Runnable() { () -> {
@Override
public void run() {
cm.execCommand("find"); cm.execCommand("find");
}
}) })
.on( .on(
"Ctrl-G", "Ctrl-G",
new Runnable() { () -> {
@Override
public void run() {
cm.execCommand("findNext"); cm.execCommand("findNext");
}
}) })
.on("Enter", maybeNextCmSearch(cm)) .on("Enter", maybeNextCmSearch(cm))
.on( .on(
"Shift-Ctrl-G", "Shift-Ctrl-G",
new Runnable() { () -> {
@Override
public void run() {
cm.execCommand("findPrev"); cm.execCommand("findPrev");
}
}) })
.on( .on(
"Shift-Enter", "Shift-Enter",
new Runnable() { () -> {
@Override
public void run() {
cm.execCommand("findPrev"); cm.execCommand("findPrev");
}
}) })
.on( .on(
"Esc", "Esc",
new Runnable() { () -> {
@Override
public void run() {
cm.setCursor(cm.getCursor()); cm.setCursor(cm.getCursor());
cm.execCommand("clearSearch"); cm.execCommand("clearSearch");
cm.vim().handleEx("nohlsearch"); cm.vim().handleEx("nohlsearch");
}
}) })
.on( .on(
"Ctrl-A", "Ctrl-A",
new Runnable() { () -> {
@Override
public void run() {
cm.execCommand("selectAll"); cm.execCommand("selectAll");
}
}) })
.on( .on(
"G O", "G O",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("status:open")); Gerrit.display(PageLinks.toChangeQuery("status:open"));
}
}) })
.on( .on(
"G M", "G M",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("status:merged")); Gerrit.display(PageLinks.toChangeQuery("status:merged"));
}
}) })
.on( .on(
"G A", "G A",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("status:abandoned")); Gerrit.display(PageLinks.toChangeQuery("status:abandoned"));
}
}); });
if (Gerrit.isSignedIn()) { if (Gerrit.isSignedIn()) {
keyMap keyMap
.on( .on(
"G I", "G I",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.MINE); Gerrit.display(PageLinks.MINE);
}
}) })
.on( .on(
"G D", "G D",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("owner:self is:draft")); Gerrit.display(PageLinks.toChangeQuery("owner:self is:draft"));
}
}) })
.on( .on(
"G C", "G C",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("has:draft")); Gerrit.display(PageLinks.toChangeQuery("has:draft"));
}
}) })
.on( .on(
"G W", "G W",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("is:watched status:open")); Gerrit.display(PageLinks.toChangeQuery("is:watched status:open"));
}
}) })
.on( .on(
"G S", "G S",
new Runnable() { () -> {
@Override
public void run() {
Gerrit.display(PageLinks.toChangeQuery("is:starred")); Gerrit.display(PageLinks.toChangeQuery("is:starred"));
}
}); });
} }
@@ -700,13 +639,10 @@ abstract class DiffScreen extends Screen {
void setContext(final int context) { void setContext(final int context) {
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
skipManager.removeAll(); skipManager.removeAll();
skipManager.render(context, diff); skipManager.render(context, diff);
updateRenderEntireFile(); updateRenderEntireFile();
}
}); });
} }
@@ -753,10 +689,8 @@ abstract class DiffScreen extends Screen {
return line - offset; return line - offset;
} }
private Runnable openEditScreen(final CodeMirror cm) { private Runnable openEditScreen(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
LineHandle handle = cm.extras().activeLine(); LineHandle handle = cm.extras().activeLine();
int line = cm.getLineNumber(handle) + 1; int line = cm.getLineNumber(handle) + 1;
if (Patch.COMMIT_MSG.equals(path)) { if (Patch.COMMIT_MSG.equals(path)) {
@@ -768,7 +702,6 @@ abstract class DiffScreen extends Screen {
} else { } else {
Gerrit.display(token); Gerrit.display(token);
} }
}
}; };
} }
@@ -832,10 +765,8 @@ abstract class DiffScreen extends Screen {
abstract void operation(Runnable apply); abstract void operation(Runnable apply);
private Runnable upToChange(final boolean openReplyBox) { private Runnable upToChange(boolean openReplyBox) {
return new Runnable() { return () -> {
@Override
public void run() {
CallbackGroup group = new CallbackGroup(); CallbackGroup group = new CallbackGroup();
getCommentManager().saveAllDrafts(group); getCommentManager().saveAllDrafts(group);
group.done(); group.done();
@@ -849,47 +780,37 @@ abstract class DiffScreen extends Screen {
new ChangeScreen(changeId, base, rev, openReplyBox, FileTable.Mode.REVIEW)); new ChangeScreen(changeId, base, rev, openReplyBox, FileTable.Mode.REVIEW));
} }
}); });
}
}; };
} }
private Runnable maybePrevVimSearch(final CodeMirror cm) { private Runnable maybePrevVimSearch(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
if (cm.vim().hasSearchHighlight()) { if (cm.vim().hasSearchHighlight()) {
cm.vim().handleKey("N"); cm.vim().handleKey("N");
} else { } else {
getCommentManager().commentNav(cm, Direction.NEXT).run(); getCommentManager().commentNav(cm, Direction.NEXT).run();
} }
}
}; };
} }
private Runnable maybeNextVimSearch(final CodeMirror cm) { private Runnable maybeNextVimSearch(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
if (cm.vim().hasSearchHighlight()) { if (cm.vim().hasSearchHighlight()) {
cm.vim().handleKey("n"); cm.vim().handleKey("n");
} else { } else {
getChunkManager().diffChunkNav(cm, Direction.NEXT).run(); getChunkManager().diffChunkNav(cm, Direction.NEXT).run();
} }
}
}; };
} }
Runnable maybeNextCmSearch(final CodeMirror cm) { Runnable maybeNextCmSearch(CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
if (cm.hasSearchHighlight()) { if (cm.hasSearchHighlight()) {
cm.execCommand("findNext"); cm.execCommand("findNext");
} else { } else {
cm.execCommand("clearSearch"); cm.execCommand("clearSearch");
getCommentManager().toggleOpenBox(cm).run(); getCommentManager().toggleOpenBox(cm).run();
} }
}
}; };
} }
@@ -973,7 +894,7 @@ abstract class DiffScreen extends Screen {
} }
void reloadDiffInfo() { void reloadDiffInfo() {
final int id = ++reloadVersionId; int id = ++reloadVersionId;
DiffApi.diff(revision, path) DiffApi.diff(revision, path)
.base(base.asPatchSetId()) .base(base.asPatchSetId())
.wholeFile() .wholeFile()
@@ -986,16 +907,13 @@ abstract class DiffScreen extends Screen {
if (id == reloadVersionId && isAttached()) { if (id == reloadVersionId && isAttached()) {
diff = diffInfo; diff = diffInfo;
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
skipManager.removeAll(); skipManager.removeAll();
getChunkManager().reset(); getChunkManager().reset();
getDiffTable().scrollbar.removeDiffAnnotations(); getDiffTable().scrollbar.removeDiffAnnotations();
setShowIntraline(prefs.intralineDifference()); setShowIntraline(prefs.intralineDifference());
render(diff); render(diff);
skipManager.render(prefs.context(), diff); skipManager.render(prefs.context(), diff);
}
}); });
} }
} }

View File

@@ -318,47 +318,32 @@ public class Header extends Composite {
} }
Runnable toggleReviewed() { Runnable toggleReviewed() {
return new Runnable() { return () -> {
@Override
public void run() {
reviewed.setValue(!reviewed.getValue(), true); reviewed.setValue(!reviewed.getValue(), true);
}
}; };
} }
Runnable navigate(Direction dir) { Runnable navigate(Direction dir) {
switch (dir) { switch (dir) {
case PREV: case PREV:
return new Runnable() { return () -> {
@Override
public void run() {
(hasPrev ? prev : up).go(); (hasPrev ? prev : up).go();
}
}; };
case NEXT: case NEXT:
return new Runnable() { return () -> {
@Override
public void run() {
(hasNext ? next : up).go(); (hasNext ? next : up).go();
}
}; };
default: default:
return new Runnable() { return () -> {};
@Override
public void run() {}
};
} }
} }
Runnable reviewedAndNext() { Runnable reviewedAndNext() {
return new Runnable() { return () -> {
@Override
public void run() {
if (Gerrit.isSignedIn()) { if (Gerrit.isSignedIn()) {
reviewed.setValue(true, true); reviewed.setValue(true, true);
} }
navigate(Direction.NEXT).run(); navigate(Direction.NEXT).run();
}
}; };
} }

View File

@@ -322,13 +322,10 @@ public class PreferencesBox extends Composite {
prefs.tabSize(Math.max(1, Integer.parseInt(v))); prefs.tabSize(Math.max(1, Integer.parseInt(v)));
if (view != null) { if (view != null) {
view.operation( view.operation(
new Runnable() { () -> {
@Override int size = prefs.tabSize();
public void run() {
int v = prefs.tabSize();
for (CodeMirror cm : view.getCms()) { for (CodeMirror cm : view.getCms()) {
cm.setOption("tabSize", v); cm.setOption("tabSize", size);
}
} }
}); });
} }
@@ -342,11 +339,8 @@ public class PreferencesBox extends Composite {
prefs.lineLength(Math.max(1, Integer.parseInt(v))); prefs.lineLength(Math.max(1, Integer.parseInt(v)));
if (view != null) { if (view != null) {
view.operation( view.operation(
new Runnable() { () -> {
@Override
public void run() {
view.setLineLength(prefs.lineLength()); view.setLineLength(prefs.lineLength());
}
}); });
} }
} }
@@ -461,12 +455,9 @@ public class PreferencesBox extends Composite {
&& Objects.equals(mode, getSelectedMode()) && Objects.equals(mode, getSelectedMode())
&& view.isAttached()) { && view.isAttached()) {
view.operation( view.operation(
new Runnable() { () -> {
@Override
public void run() {
view.getCmFromSide(DisplaySide.A).setOption("mode", mode); view.getCmFromSide(DisplaySide.A).setOption("mode", mode);
view.getCmFromSide(DisplaySide.B).setOption("mode", mode); view.getCmFromSide(DisplaySide.B).setOption("mode", mode);
}
}); });
} }
} }
@@ -483,14 +474,11 @@ public class PreferencesBox extends Composite {
prefs.showWhitespaceErrors(e.getValue()); prefs.showWhitespaceErrors(e.getValue());
if (view != null) { if (view != null) {
view.operation( view.operation(
new Runnable() { () -> {
@Override
public void run() {
boolean s = prefs.showWhitespaceErrors(); boolean s = prefs.showWhitespaceErrors();
for (CodeMirror cm : view.getCms()) { for (CodeMirror cm : view.getCms()) {
cm.setOption("showTrailingSpace", s); cm.setOption("showTrailingSpace", s);
} }
}
}); });
} }
} }
@@ -546,16 +534,13 @@ public class PreferencesBox extends Composite {
@Override @Override
public void onSuccess(Void result) { public void onSuccess(Void result) {
view.operation( view.operation(
new Runnable() { () -> {
@Override
public void run() {
if (getSelectedTheme() == newTheme && isAttached()) { if (getSelectedTheme() == newTheme && isAttached()) {
String t = newTheme.name().toLowerCase(); String t = newTheme.name().toLowerCase();
view.getCmFromSide(DisplaySide.A).setOption("theme", t); view.getCmFromSide(DisplaySide.A).setOption("theme", t);
view.getCmFromSide(DisplaySide.B).setOption("theme", t); view.getCmFromSide(DisplaySide.B).setOption("theme", t);
view.setThemeStyles(newTheme.isDark()); view.setThemeStyles(newTheme.isDark());
} }
}
}); });
} }
}); });

View File

@@ -64,13 +64,10 @@ class ScrollbarAnnotation extends Widget implements ClickHandler {
refresh = refresh =
cmB.on( cmB.on(
"refresh", "refresh",
new Runnable() { () -> {
@Override
public void run() {
if (updateScale()) { if (updateScale()) {
updatePosition(); updatePosition();
} }
}
}); });
updateScale(); updateScale();
updatePosition(); updatePosition();

View File

@@ -102,14 +102,11 @@ public class SideBySide extends DiffScreen {
super.onShowView(); super.onShowView();
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
resizeCodeMirror(); resizeCodeMirror();
chunkManager.adjustPadding(); chunkManager.adjustPadding();
cmA.refresh(); cmA.refresh();
cmB.refresh(); cmB.refresh();
}
}); });
setLineLength(Patch.COMMIT_MSG.equals(path) ? 72 : prefs.lineLength()); setLineLength(Patch.COMMIT_MSG.equals(path) ? 72 : prefs.lineLength());
diffTable.refresh(); diffTable.refresh();
@@ -209,9 +206,7 @@ public class SideBySide extends DiffScreen {
chunkManager = new SideBySideChunkManager(this, cmA, cmB, diffTable.scrollbar); chunkManager = new SideBySideChunkManager(this, cmA, cmB, diffTable.scrollbar);
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
// Estimate initial CodeMirror height, fixed up in onShowView. // Estimate initial CodeMirror height, fixed up in onShowView.
int height = Window.getClientHeight() - (Gerrit.getHeaderFooterHeight() + 18); int height = Window.getClientHeight() - (Gerrit.getHeaderFooterHeight() + 18);
cmA.setHeight(height); cmA.setHeight(height);
@@ -220,7 +215,6 @@ public class SideBySide extends DiffScreen {
render(diff); render(diff);
commentManager.render(comments, prefs.expandAllComments()); commentManager.render(comments, prefs.expandAllComments());
skipManager.render(prefs.context(), diff); skipManager.render(prefs.context(), diff);
}
}); });
registerCmEvents(cmA); registerCmEvents(cmA);
@@ -321,9 +315,7 @@ public class SideBySide extends DiffScreen {
@Override @Override
Runnable updateActiveLine(final CodeMirror cm) { Runnable updateActiveLine(final CodeMirror cm) {
final CodeMirror other = otherCm(cm); final CodeMirror other = otherCm(cm);
return new Runnable() { return () -> {
@Override
public void run() {
// The rendering of active lines has to be deferred. Reflow // The rendering of active lines has to be deferred. Reflow
// caused by adding and removing styles chokes Firefox when arrow // caused by adding and removing styles chokes Firefox when arrow
// key (or j/k) is held down. Performance on Chrome is fine // key (or j/k) is held down. Performance on Chrome is fine
@@ -335,11 +327,8 @@ public class SideBySide extends DiffScreen {
@Override @Override
public void execute() { public void execute() {
operation( operation(
new Runnable() { () -> {
@Override LineHandle handle = cm.getLineHandleVisualStart(cm.getCursor("end").line());
public void run() {
LineHandle handle =
cm.getLineHandleVisualStart(cm.getCursor("end").line());
if (!cm.extras().activeLine(handle)) { if (!cm.extras().activeLine(handle)) {
return; return;
} }
@@ -350,35 +339,26 @@ public class SideBySide extends DiffScreen {
} else { } else {
other.extras().clearActiveLine(); other.extras().clearActiveLine();
} }
}
}); });
} }
}); });
}
}; };
} }
private Runnable moveCursorToSide(final CodeMirror cmSrc, DisplaySide sideDst) { private Runnable moveCursorToSide(final CodeMirror cmSrc, DisplaySide sideDst) {
final CodeMirror cmDst = getCmFromSide(sideDst); final CodeMirror cmDst = getCmFromSide(sideDst);
if (cmDst == cmSrc) { if (cmDst == cmSrc) {
return new Runnable() { return () -> {};
@Override
public void run() {}
};
} }
final DisplaySide sideSrc = cmSrc.side(); final DisplaySide sideSrc = cmSrc.side();
return new Runnable() { return () -> {
@Override
public void run() {
if (cmSrc.extras().hasActiveLine()) { if (cmSrc.extras().hasActiveLine()) {
cmDst.setCursor( cmDst.setCursor(
Pos.create( Pos.create(
lineOnOther(sideSrc, cmSrc.getLineNumber(cmSrc.extras().activeLine())) lineOnOther(sideSrc, cmSrc.getLineNumber(cmSrc.extras().activeLine())).getLine()));
.getLine()));
} }
cmDst.focus(); cmDst.focus();
}
}; };
} }
@@ -389,19 +369,10 @@ public class SideBySide extends DiffScreen {
} }
@Override @Override
void operation(final Runnable apply) { void operation(Runnable apply) {
cmA.operation( cmA.operation(
new Runnable() { () -> {
@Override cmB.operation(apply::run);
public void run() {
cmB.operation(
new Runnable() {
@Override
public void run() {
apply.run();
}
});
}
}); });
} }

View File

@@ -246,15 +246,12 @@ class SideBySideChunkManager extends ChunkManager {
@Override @Override
Runnable diffChunkNav(final CodeMirror cm, final Direction dir) { Runnable diffChunkNav(final CodeMirror cm, final Direction dir) {
return new Runnable() { return () -> {
@Override
public void run() {
int line = cm.extras().hasActiveLine() ? cm.getLineNumber(cm.extras().activeLine()) : 0; int line = cm.extras().hasActiveLine() ? cm.getLineNumber(cm.extras().activeLine()) : 0;
int res = int res =
Collections.binarySearch( Collections.binarySearch(
chunks, new DiffChunkInfo(cm.side(), line, 0, false), getDiffChunkComparator()); chunks, new DiffChunkInfo(cm.side(), line, 0, false), getDiffChunkComparator());
diffChunkNavHelper(chunks, host, res, dir); diffChunkNavHelper(chunks, host, res, dir);
}
}; };
} }

View File

@@ -88,9 +88,7 @@ class SideBySideCommentGroup extends CommentGroup implements Comparable<SideBySi
void handleRedraw() { void handleRedraw() {
getLineWidget() getLineWidget()
.onRedraw( .onRedraw(
new Runnable() { () -> {
@Override
public void run() {
if (canComputeHeight() && peers.peek().canComputeHeight()) { if (canComputeHeight() && peers.peek().canComputeHeight()) {
if (getResizeTimer() != null) { if (getResizeTimer() != null) {
getResizeTimer().cancel(); getResizeTimer().cancel();
@@ -111,7 +109,6 @@ class SideBySideCommentGroup extends CommentGroup implements Comparable<SideBySi
}); });
getResizeTimer().scheduleRepeating(5); getResizeTimer().scheduleRepeating(5);
} }
}
}); });
} }

View File

@@ -75,11 +75,8 @@ class SideBySideTable extends DiffTable {
} }
Runnable toggleA() { Runnable toggleA() {
return new Runnable() { return () -> {
@Override
public void run() {
setVisibleA(!isVisibleA()); setVisibleA(!isVisibleA());
}
}; };
} }

View File

@@ -91,12 +91,9 @@ class SkipBar extends Composite {
} }
if (isNew) { if (isNew) {
lineWidget.onFirstRedraw( lineWidget.onFirstRedraw(
new Runnable() { () -> {
@Override
public void run() {
int w = cm.getGutterElement().getOffsetWidth(); int w = cm.getGutterElement().getOffsetWidth();
getElement().getStyle().setPaddingLeft(w, Unit.PX); getElement().getStyle().setPaddingLeft(w, Unit.PX);
}
}); });
} }
} }
@@ -110,14 +107,7 @@ class SkipBar extends Composite {
.set("inclusiveLeft", true) .set("inclusiveLeft", true)
.set("inclusiveRight", true)); .set("inclusiveRight", true));
textMarker.on( textMarker.on("beforeCursorEnter", this::expandAll);
"beforeCursorEnter",
new Runnable() {
@Override
public void run() {
expandAll();
}
});
int skipped = end - start + 1; int skipped = end - start + 1;
if (skipped <= UP_DOWN_THRESHOLD) { if (skipped <= UP_DOWN_THRESHOLD) {

View File

@@ -30,7 +30,6 @@ import com.google.gwt.core.client.GWT;
import com.google.gwt.core.client.JavaScriptObject; import com.google.gwt.core.client.JavaScriptObject;
import com.google.gwt.core.client.JsArrayString; import com.google.gwt.core.client.JsArrayString;
import com.google.gwt.core.client.Scheduler; import com.google.gwt.core.client.Scheduler;
import com.google.gwt.core.client.Scheduler.ScheduledCommand;
import com.google.gwt.dom.client.Element; import com.google.gwt.dom.client.Element;
import com.google.gwt.event.dom.client.FocusEvent; import com.google.gwt.event.dom.client.FocusEvent;
import com.google.gwt.event.dom.client.FocusHandler; import com.google.gwt.event.dom.client.FocusHandler;
@@ -102,12 +101,9 @@ public class Unified extends DiffScreen {
super.onShowView(); super.onShowView();
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
resizeCodeMirror(); resizeCodeMirror();
cm.refresh(); cm.refresh();
}
}); });
setLineLength(Patch.COMMIT_MSG.equals(path) ? 72 : prefs.lineLength()); setLineLength(Patch.COMMIT_MSG.equals(path) ? 72 : prefs.lineLength());
diffTable.refresh(); diffTable.refresh();
@@ -142,14 +138,11 @@ public class Unified extends DiffScreen {
cm.on( cm.on(
"scroll", "scroll",
new Runnable() { () -> {
@Override
public void run() {
ScrollInfo si = cm.getScrollInfo(); ScrollInfo si = cm.getScrollInfo();
if (autoHideDiffTableHeader) { if (autoHideDiffTableHeader) {
updateDiffTableHeader(si); updateDiffTableHeader(si);
} }
}
}); });
maybeRegisterRenderEntireFileKeyMap(cm); maybeRegisterRenderEntireFileKeyMap(cm);
} }
@@ -186,9 +179,7 @@ public class Unified extends DiffScreen {
chunkManager = new UnifiedChunkManager(this, cm, diffTable.scrollbar); chunkManager = new UnifiedChunkManager(this, cm, diffTable.scrollbar);
operation( operation(
new Runnable() { () -> {
@Override
public void run() {
// Estimate initial CodeMirror height, fixed up in onShowView. // Estimate initial CodeMirror height, fixed up in onShowView.
int height = Window.getClientHeight() - (Gerrit.getHeaderFooterHeight() + 18); int height = Window.getClientHeight() - (Gerrit.getHeaderFooterHeight() + 18);
cm.setHeight(height); cm.setHeight(height);
@@ -196,7 +187,6 @@ public class Unified extends DiffScreen {
render(diff); render(diff);
commentManager.render(comments, prefs.expandAllComments()); commentManager.render(comments, prefs.expandAllComments());
skipManager.render(prefs.context(), diff); skipManager.render(prefs.context(), diff);
}
}); });
registerCmEvents(cm); registerCmEvents(cm);
@@ -318,9 +308,7 @@ public class Unified extends DiffScreen {
@Override @Override
Runnable updateActiveLine(final CodeMirror cm) { Runnable updateActiveLine(final CodeMirror cm) {
return new Runnable() { return () -> {
@Override
public void run() {
// The rendering of active lines has to be deferred. Reflow // The rendering of active lines has to be deferred. Reflow
// caused by adding and removing styles chokes Firefox when arrow // caused by adding and removing styles chokes Firefox when arrow
// key (or j/k) is held down. Performance on Chrome is fine // key (or j/k) is held down. Performance on Chrome is fine
@@ -328,14 +316,10 @@ public class Unified extends DiffScreen {
// //
Scheduler.get() Scheduler.get()
.scheduleDeferred( .scheduleDeferred(
new ScheduledCommand() { () -> {
@Override
public void execute() {
LineHandle handle = cm.getLineHandleVisualStart(cm.getCursor("end").line()); LineHandle handle = cm.getLineHandleVisualStart(cm.getCursor("end").line());
cm.extras().activeLine(handle); cm.extras().activeLine(handle);
}
}); });
}
}; };
} }
@@ -354,14 +338,8 @@ public class Unified extends DiffScreen {
} }
@Override @Override
void operation(final Runnable apply) { void operation(Runnable apply) {
cm.operation( cm.operation(apply::run);
new Runnable() {
@Override
public void run() {
apply.run();
}
});
} }
@Override @Override

View File

@@ -214,9 +214,7 @@ class UnifiedChunkManager extends ChunkManager {
@Override @Override
Runnable diffChunkNav(final CodeMirror cm, final Direction dir) { Runnable diffChunkNav(final CodeMirror cm, final Direction dir) {
return new Runnable() { return () -> {
@Override
public void run() {
int line = cm.extras().hasActiveLine() ? cm.getLineNumber(cm.extras().activeLine()) : 0; int line = cm.extras().hasActiveLine() ? cm.getLineNumber(cm.extras().activeLine()) : 0;
int res = int res =
Collections.binarySearch( Collections.binarySearch(
@@ -224,7 +222,6 @@ class UnifiedChunkManager extends ChunkManager {
new UnifiedDiffChunkInfo(cm.side(), 0, 0, line, false), new UnifiedDiffChunkInfo(cm.side(), 0, 0, line, false),
getDiffChunkComparatorCmLine()); getDiffChunkComparatorCmLine());
diffChunkNavHelper(chunks, host, res, dir); diffChunkNavHelper(chunks, host, res, dir);
}
}; };
} }

View File

@@ -50,9 +50,7 @@ class UnifiedCommentGroup extends CommentGroup {
void handleRedraw() { void handleRedraw() {
getLineWidget() getLineWidget()
.onRedraw( .onRedraw(
new Runnable() { () -> {
@Override
public void run() {
if (canComputeHeight()) { if (canComputeHeight()) {
if (getResizeTimer() != null) { if (getResizeTimer() != null) {
getResizeTimer().cancel(); getResizeTimer().cancel();
@@ -73,7 +71,6 @@ class UnifiedCommentGroup extends CommentGroup {
}); });
getResizeTimer().scheduleRepeating(5); getResizeTimer().scheduleRepeating(5);
} }
}
}); });
} }

View File

@@ -49,7 +49,6 @@ import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gwt.core.client.GWT; import com.google.gwt.core.client.GWT;
import com.google.gwt.core.client.JsArray; import com.google.gwt.core.client.JsArray;
import com.google.gwt.core.client.Scheduler; import com.google.gwt.core.client.Scheduler;
import com.google.gwt.core.client.Scheduler.ScheduledCommand;
import com.google.gwt.dom.client.Element; import com.google.gwt.dom.client.Element;
import com.google.gwt.dom.client.Style.Unit; import com.google.gwt.dom.client.Style.Unit;
import com.google.gwt.event.dom.client.ClickEvent; import com.google.gwt.event.dom.client.ClickEvent;
@@ -318,11 +317,8 @@ public class EditScreen extends Screen {
} }
private Runnable gotoLine() { private Runnable gotoLine() {
return new Runnable() { return () -> {
@Override
public void run() {
cmEdit.execCommand("jumpToLine"); cmEdit.execCommand("jumpToLine");
}
}; };
} }
@@ -474,18 +470,12 @@ public class EditScreen extends Screen {
void setTheme(final Theme newTheme) { void setTheme(final Theme newTheme) {
cmBase.operation( cmBase.operation(
new Runnable() { () -> {
@Override
public void run() {
cmBase.setOption("theme", newTheme.name().toLowerCase()); cmBase.setOption("theme", newTheme.name().toLowerCase());
}
}); });
cmEdit.operation( cmEdit.operation(
new Runnable() { () -> {
@Override
public void run() {
cmEdit.setOption("theme", newTheme.name().toLowerCase()); cmEdit.setOption("theme", newTheme.name().toLowerCase());
}
}); });
} }
@@ -506,18 +496,12 @@ public class EditScreen extends Screen {
void setShowWhitespaceErrors(final boolean show) { void setShowWhitespaceErrors(final boolean show) {
cmBase.operation( cmBase.operation(
new Runnable() { () -> {
@Override
public void run() {
cmBase.setOption("showTrailingSpace", show); cmBase.setOption("showTrailingSpace", show);
}
}); });
cmEdit.operation( cmEdit.operation(
new Runnable() { () -> {
@Override
public void run() {
cmEdit.setOption("showTrailingSpace", show); cmEdit.setOption("showTrailingSpace", show);
}
}); });
} }
@@ -643,9 +627,7 @@ public class EditScreen extends Screen {
} }
private Runnable updateCursorPosition() { private Runnable updateCursorPosition() {
return new Runnable() { return () -> {
@Override
public void run() {
// The rendering of active lines has to be deferred. Reflow // The rendering of active lines has to be deferred. Reflow
// caused by adding and removing styles chokes Firefox when arrow // caused by adding and removing styles chokes Firefox when arrow
// key (or j/k) is held down. Performance on Chrome is fine // key (or j/k) is held down. Performance on Chrome is fine
@@ -653,19 +635,9 @@ public class EditScreen extends Screen {
// //
Scheduler.get() Scheduler.get()
.scheduleDeferred( .scheduleDeferred(
new ScheduledCommand() { () -> {
@Override cmEdit.operation(this::updateActiveLine);
public void execute() {
cmEdit.operation(
new Runnable() {
@Override
public void run() {
updateActiveLine();
}
}); });
}
});
}
}; };
} }
@@ -683,9 +655,7 @@ public class EditScreen extends Screen {
} }
private Runnable save() { private Runnable save() {
return new Runnable() { return () -> {
@Override
public void run() {
if (!cmEdit.isClean(generation)) { if (!cmEdit.isClean(generation)) {
close.setEnabled(false); close.setEnabled(false);
String text = cmEdit.getValue(); String text = cmEdit.getValue();
@@ -714,7 +684,6 @@ public class EditScreen extends Screen {
} }
}); });
} }
}
}; };
} }

View File

@@ -121,9 +121,7 @@ public abstract class AbstractLuceneIndex<K, V> implements Index<K, V> {
@SuppressWarnings("unused") // Error handling within Runnable. @SuppressWarnings("unused") // Error handling within Runnable.
Future<?> possiblyIgnoredError = Future<?> possiblyIgnoredError =
autoCommitExecutor.scheduleAtFixedRate( autoCommitExecutor.scheduleAtFixedRate(
new Runnable() { () -> {
@Override
public void run() {
try { try {
if (autoCommitWriter.hasUncommittedChanges()) { if (autoCommitWriter.hasUncommittedChanges()) {
autoCommitWriter.manualFlush(); autoCommitWriter.manualFlush();
@@ -144,7 +142,6 @@ public abstract class AbstractLuceneIndex<K, V> implements Index<K, V> {
e); e);
} }
} }
}
}, },
commitPeriod, commitPeriod,
commitPeriod, commitPeriod,

View File

@@ -228,12 +228,9 @@ public class Daemon extends SiteProgram {
try { try {
start(); start();
RuntimeShutdown.add( RuntimeShutdown.add(
new Runnable() { () -> {
@Override
public void run() {
log.info("caught shutdown, cleaning up"); log.info("caught shutdown, cleaning up");
stop(); stop();
}
}); });
log.info("Gerrit Code Review " + myVersion() + " ready"); log.info("Gerrit Code Review " + myVersion() + " ready");

View File

@@ -45,16 +45,13 @@ public class Gsql extends SiteProgram {
manager.add(dbInjector); manager.add(dbInjector);
manager.start(); manager.start();
RuntimeShutdown.add( RuntimeShutdown.add(
new Runnable() { () -> {
@Override
public void run() {
try { try {
System.in.close(); System.in.close();
} catch (IOException e) { } catch (IOException e) {
// Ignored // Ignored
} }
manager.stop(); manager.stop();
}
}); });
final QueryShell shell = shellFactory().create(System.in, System.out); final QueryShell shell = shellFactory().create(System.in, System.out);
shell.setOutputFormat(format); shell.setOutputFormat(format);

View File

@@ -85,13 +85,7 @@ public class ProtobufImport extends SiteProgram {
Injector dbInjector = createDbInjector(SINGLE_USER); Injector dbInjector = createDbInjector(SINGLE_USER);
manager.add(dbInjector); manager.add(dbInjector);
manager.start(); manager.start();
RuntimeShutdown.add( RuntimeShutdown.add(manager::stop);
new Runnable() {
@Override
public void run() {
manager.stop();
}
});
dbInjector.injectMembers(this); dbInjector.injectMembers(this);
ProgressMonitor progress = new TextProgressMonitor(); ProgressMonitor progress = new TextProgressMonitor();

View File

@@ -79,19 +79,16 @@ public abstract class MetricMaker {
* @param value only value of the metric. * @param value only value of the metric.
* @param desc description of the metric. * @param desc description of the metric.
*/ */
public <V> void newConstantMetric(String name, final V value, Description desc) { public <V> void newConstantMetric(String name, V value, Description desc) {
desc.setConstant(); desc.setConstant();
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Class<V> type = (Class<V>) value.getClass(); Class<V> type = (Class<V>) value.getClass();
final CallbackMetric0<V> metric = newCallbackMetric(name, type, desc); CallbackMetric0<V> metric = newCallbackMetric(name, type, desc);
newTrigger( newTrigger(
metric, metric,
new Runnable() { () -> {
@Override
public void run() {
metric.set(value); metric.set(value);
}
}); });
} }
@@ -116,15 +113,12 @@ public abstract class MetricMaker {
* @param trigger function to compute the value of the metric. * @param trigger function to compute the value of the metric.
*/ */
public <V> void newCallbackMetric( public <V> void newCallbackMetric(
String name, Class<V> valueClass, Description desc, final Supplier<V> trigger) { String name, Class<V> valueClass, Description desc, Supplier<V> trigger) {
final CallbackMetric0<V> metric = newCallbackMetric(name, valueClass, desc); CallbackMetric0<V> metric = newCallbackMetric(name, valueClass, desc);
newTrigger( newTrigger(
metric, metric,
new Runnable() { () -> {
@Override
public void run() {
metric.set(trigger.get()); metric.set(trigger.get());
}
}); });
} }

View File

@@ -147,9 +147,7 @@ public class ProcMetricModule extends MetricModule {
metrics.newTrigger( metrics.newTrigger(
ImmutableSet.<CallbackMetric<?>>of( ImmutableSet.<CallbackMetric<?>>of(
heapCommitted, heapUsed, nonHeapCommitted, nonHeapUsed, objectPendingFinalizationCount), heapCommitted, heapUsed, nonHeapCommitted, nonHeapUsed, objectPendingFinalizationCount),
new Runnable() { () -> {
@Override
public void run() {
try { try {
MemoryUsage stats = memory.getHeapMemoryUsage(); MemoryUsage stats = memory.getHeapMemoryUsage();
heapCommitted.set(stats.getCommitted()); heapCommitted.set(stats.getCommitted());
@@ -163,7 +161,6 @@ public class ProcMetricModule extends MetricModule {
nonHeapUsed.set(stats.getUsed()); nonHeapUsed.set(stats.getUsed());
objectPendingFinalizationCount.set(memory.getObjectPendingFinalizationCount()); objectPendingFinalizationCount.set(memory.getObjectPendingFinalizationCount());
}
}); });
} }
@@ -187,9 +184,7 @@ public class ProcMetricModule extends MetricModule {
metrics.newTrigger( metrics.newTrigger(
gcCount, gcCount,
gcTime, gcTime,
new Runnable() { () -> {
@Override
public void run() {
for (GarbageCollectorMXBean gc : ManagementFactory.getGarbageCollectorMXBeans()) { for (GarbageCollectorMXBean gc : ManagementFactory.getGarbageCollectorMXBeans()) {
long count = gc.getCollectionCount(); long count = gc.getCollectionCount();
if (count != -1) { if (count != -1) {
@@ -200,7 +195,6 @@ public class ProcMetricModule extends MetricModule {
gcTime.set(gc.getName(), time); gcTime.set(gc.getName(), time);
} }
} }
}
}); });
} }

View File

@@ -119,19 +119,13 @@ public final class StoredValues {
GitRepositoryManager gitMgr = env.getArgs().getGitRepositoryManager(); GitRepositoryManager gitMgr = env.getArgs().getGitRepositoryManager();
Change change = getChange(engine); Change change = getChange(engine);
Project.NameKey projectKey = change.getProject(); Project.NameKey projectKey = change.getProject();
final Repository repo; Repository repo;
try { try {
repo = gitMgr.openRepository(projectKey); repo = gitMgr.openRepository(projectKey);
} catch (IOException e) { } catch (IOException e) {
throw new SystemException(e.getMessage()); throw new SystemException(e.getMessage());
} }
env.addToCleanup( env.addToCleanup(repo::close);
new Runnable() {
@Override
public void run() {
repo.close();
}
});
return repo; return repo;
} }
}; };

View File

@@ -69,9 +69,7 @@ public class CacheMetrics {
metrics.newTrigger( metrics.newTrigger(
cacheMetrics, cacheMetrics,
new Runnable() { () -> {
@Override
public void run() {
for (DynamicMap.Entry<Cache<?, ?>> e : cacheMap) { for (DynamicMap.Entry<Cache<?, ?>> e : cacheMap) {
Cache<?, ?> c = e.getProvider().get(); Cache<?, ?> c = e.getProvider().get();
String name = metricNameOf(e); String name = metricNameOf(e);
@@ -88,7 +86,6 @@ public class CacheMetrics {
for (CallbackMetric<?> cbm : cacheMetrics) { for (CallbackMetric<?> cbm : cacheMetrics) {
cbm.prune(); cbm.prune();
} }
}
}); });
} }

View File

@@ -51,12 +51,9 @@ public class RequestScopedReviewDbProvider implements Provider<ReviewDb> {
cleanup cleanup
.get() .get()
.add( .add(
new Runnable() { () -> {
@Override
public void run() {
c.close(); c.close();
db = null; db = null;
}
}); });
} catch (Throwable e) { } catch (Throwable e) {
c.close(); c.close();

View File

@@ -54,16 +54,11 @@ public class ProjectCacheWarmer implements LifecycleListener {
log.info("Loading project cache"); log.info("Loading project cache");
scheduler.execute( scheduler.execute(
new Runnable() { () -> {
@Override
public void run() {
for (final Project.NameKey name : cache.all()) { for (final Project.NameKey name : cache.all()) {
pool.execute( pool.execute(
new Runnable() { () -> {
@Override
public void run() {
cache.get(name); cache.get(name);
}
}); });
} }
pool.shutdown(); pool.shutdown();
@@ -73,7 +68,6 @@ public class ProjectCacheWarmer implements LifecycleListener {
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.warn("Interrupted while waiting for project cache to load"); log.warn("Interrupted while waiting for project cache to load");
} }
}
}); });
} }
} }

View File

@@ -161,8 +161,8 @@ public class DataSourceProvider implements Provider<DataSource>, LifecycleListen
} }
} }
private void exportPoolMetrics(final BasicDataSource pool) { private void exportPoolMetrics(BasicDataSource pool) {
final CallbackMetric1<Boolean, Integer> cnt = CallbackMetric1<Boolean, Integer> cnt =
metrics.newCallbackMetric( metrics.newCallbackMetric(
"sql/connection_pool/connections", "sql/connection_pool/connections",
Integer.class, Integer.class,
@@ -170,14 +170,11 @@ public class DataSourceProvider implements Provider<DataSource>, LifecycleListen
Field.ofBoolean("active")); Field.ofBoolean("active"));
metrics.newTrigger( metrics.newTrigger(
cnt, cnt,
new Runnable() { () -> {
@Override
public void run() {
synchronized (pool) { synchronized (pool) {
cnt.set(true, pool.getNumActive()); cnt.set(true, pool.getNumActive());
cnt.set(false, pool.getNumIdle()); cnt.set(false, pool.getNumIdle());
} }
}
}); });
} }

View File

@@ -133,12 +133,9 @@ public class ProcMetricModuleTest {
final AtomicInteger invocations = new AtomicInteger(0); final AtomicInteger invocations = new AtomicInteger(0);
metrics.newTrigger( metrics.newTrigger(
cntr, cntr,
new Runnable() { () -> {
@Override
public void run() {
invocations.getAndIncrement(); invocations.getAndIncrement();
cntr.set(42L); cntr.set(42L);
}
}); });
// Triggers run immediately with DropWizard binding. // Triggers run immediately with DropWizard binding.

View File

@@ -159,15 +159,12 @@ public class RepoSequenceTest {
// Seed existing ref value. // Seed existing ref value.
writeBlob("id", "1"); writeBlob("id", "1");
final AtomicBoolean doneBgUpdate = new AtomicBoolean(false); AtomicBoolean doneBgUpdate = new AtomicBoolean(false);
Runnable bgUpdate = Runnable bgUpdate =
new Runnable() { () -> {
@Override
public void run() {
if (!doneBgUpdate.getAndSet(true)) { if (!doneBgUpdate.getAndSet(true)) {
writeBlob("id", "1234"); writeBlob("id", "1234");
} }
}
}; };
RepoSequence s = newSequence("id", 1, 10, bgUpdate, RETRYER); RepoSequence s = newSequence("id", 1, 10, bgUpdate, RETRYER);
@@ -203,13 +200,10 @@ public class RepoSequenceTest {
@Test @Test
public void failAfterRetryerGivesUp() throws Exception { public void failAfterRetryerGivesUp() throws Exception {
final AtomicInteger bgCounter = new AtomicInteger(1234); AtomicInteger bgCounter = new AtomicInteger(1234);
Runnable bgUpdate = Runnable bgUpdate =
new Runnable() { () -> {
@Override
public void run() {
writeBlob("id", Integer.toString(bgCounter.getAndAdd(1000))); writeBlob("id", Integer.toString(bgCounter.getAndAdd(1000)));
}
}; };
RepoSequence s = RepoSequence s =
newSequence( newSequence(

View File

@@ -230,13 +230,7 @@ class CommandFactoryProvider implements Provider<CommandFactory>, LifecycleListe
Future<?> future = task.getAndSet(null); Future<?> future = task.getAndSet(null);
if (future != null) { if (future != null) {
future.cancel(true); future.cancel(true);
destroyExecutor.execute( destroyExecutor.execute(this::onDestroy);
new Runnable() {
@Override
public void run() {
onDestroy();
}
});
} }
} }