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

prevent overriding users output by "Process finished" (IDEA-83311)

Browse Source
This commit is contained in:
anna
2012-03-22 14:14:39 +01:00
parent 3e8a509f50
commit 039d9708b9
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/execution/impl/src/com/intellij/execution/junit2/segments/Extractor.java
+3 -2
View File
@@ -30,6 +30,7 @@ import org.jetbrains.annotations.NotNull;
import java.io.InputStream;
import java.io.Reader;
import java.nio.charset.Charset;
import java.util.concurrent.atomic.AtomicInteger;
/**
* @author dyoma
@@ -40,7 +41,7 @@ public class Extractor implements Disposable {
private OutputPacketProcessor myEventsDispatcher;
private static final Logger LOG = Logger.getInstance("#" + Extractor.class.getName());
private final MergingUpdateQueue myQueue = new MergingUpdateQueue("Test Extractor", 20, true, MergingUpdateQueue.ANY_COMPONENT);
private int myOrder = -1;
private AtomicInteger myOrder = new AtomicInteger(-1);
public Extractor(@NotNull InputStream stream, @NotNull Charset charset) {
myStream = new SegmentedInputStream(stream, charset);
@@ -66,7 +67,7 @@ public class Extractor implements Disposable {
myFulfilledWorkGate = new DeferredActionsQueue() { //todo make it all later
@Override
public void addLast(final Runnable runnable) {
myQueue.queue(new MyUpdate(runnable, queue, myOrder++));
myQueue.queue(new MyUpdate(runnable, queue, myOrder.incrementAndGet()));
}
@Override