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

QueueProcessor: survive on LOG.error in tests (more correct)

Browse Source
This commit is contained in:
Anton Makeev
2012-08-23 16:43:51 +02:00
parent d852a80fd6
commit e45ba162d0
1 changed files with 25 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-api/src/com/intellij/util/concurrency/QueueProcessor.java
+25 -21
View File
@@ -77,18 +77,13 @@ public class QueueProcessor<T> {
private static <T> PairConsumer<T, Runnable> wrappingProcessor(final Consumer<T> processor) {
return new PairConsumer<T, Runnable>() {
@Override
public void consume(T item, Runnable runnable) {
try {
processor.consume(item);
}
catch (Throwable e) {
try {
LOG.error(e);
public void consume(final T item, Runnable runnable) {
runSafely(new Runnable() {
@Override
public void run() {
processor.consume(item);
}
catch (Exception ignore) {
// should survive assertions
}
}
});
runnable.run();
}
};
@@ -202,17 +197,12 @@ public class QueueProcessor<T> {
@Override
public void run() {
if (myDeathCondition.value(null)) return;
try {
myProcessor.consume(item, myContinuationContext);
}
catch (Throwable t) {
try {
LOG.error(t);
runSafely(new Runnable() {
@Override
public void run() {
myProcessor.consume(item, myContinuationContext);
}
catch (Throwable e2) {
e2.printStackTrace();
}
}
});
}
};
final Application application = ApplicationManager.getApplication();
@@ -231,6 +221,20 @@ public class QueueProcessor<T> {
return true;
}
public static void runSafely(Runnable run) {
try {
run.run();
}
catch (Throwable e) {
try {
LOG.error(e);
}
catch (Throwable e2) {
e2.printStackTrace();
}
}
}
public boolean isEmpty() {
synchronized (myQueue) {
return myQueue.isEmpty() && (!isProcessing);