From 4d39fa86914223664f77f1b1742834fc45c21ad4 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Wed, 4 Feb 2015 13:42:10 +0100
Subject: [PATCH] added logger to AbstractInterThreadPipe
---
src/main/java/teetime/framework/AbstractInterThreadPipe.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/src/main/java/teetime/framework/AbstractInterThreadPipe.java b/src/main/java/teetime/framework/AbstractInterThreadPipe.java
index 5b11b35f..d359cf92 100644
--- a/src/main/java/teetime/framework/AbstractInterThreadPipe.java
+++ b/src/main/java/teetime/framework/AbstractInterThreadPipe.java
@@ -7,11 +7,14 @@ import org.jctools.queues.QueueFactory;
import org.jctools.queues.spec.ConcurrentQueueSpec;
import org.jctools.queues.spec.Ordering;
import org.jctools.queues.spec.Preference;
+import org.slf4j.LoggerFactory;
import teetime.framework.signal.ISignal;
public abstract class AbstractInterThreadPipe extends AbstractPipe {
+ private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(AbstractInterThreadPipe.class);
+
private final Queue<ISignal> signalQueue = QueueFactory.newQueue(new ConcurrentQueueSpec(1, 1, 0, Ordering.FIFO, Preference.THROUGHPUT));
protected <T> AbstractInterThreadPipe(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
@@ -24,7 +27,7 @@ public abstract class AbstractInterThreadPipe extends AbstractPipe {
Thread owningThread = cachedTargetStage.getOwningThread();
if (owningThread == null) {
- System.err.println("cachedTargetStage: " + cachedTargetStage);
+ LOGGER.warn("owningThread of " + cachedTargetStage + " is null.");
}
if (null != owningThread && isThreadWaiting(owningThread)) { // FIXME remove the null check for performance
owningThread.interrupt();
--
GitLab