some disruptor improvements

src/explorviz/live_trace_processing/reader/TCPReader.java

@@ -5,17 +5,19 @@ import java.net.InetSocketAddress;
 import java.nio.channels.ServerSocketChannel;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.lmax.disruptor.BlockingWaitStrategy;
 import com.lmax.disruptor.EventHandler;
 import com.lmax.disruptor.RingBuffer;
 import com.lmax.disruptor.dsl.Disruptor;
+import com.lmax.disruptor.dsl.ProducerType;
 
 import explorviz.live_trace_processing.Constants;
-import explorviz.live_trace_processing.filter.AbstractFilter;
 import explorviz.live_trace_processing.filter.RecordArrayEvent;
 import explorviz.live_trace_processing.filter.RecordArrayEventFactory;
 import explorviz.live_trace_processing.filter.reconstruction.ITraceReconstruction;
@@ -40,7 +42,8 @@ public final class TCPReader implements IPeriodicTimeSignalReceiver {
 
 		final Disruptor<RecordArrayEvent> disruptor = new Disruptor<RecordArrayEvent>(
 				new RecordArrayEventFactory(Constants.TCP_READER_OUTPUT_BUFFER_SIZE),
-				Constants.TCP_READER_DISRUPTOR_SIZE, AbstractFilter.cachedThreadPool);
+				Constants.TCP_READER_DISRUPTOR_SIZE, Executors.newCachedThreadPool(),
+				ProducerType.MULTI, new BlockingWaitStrategy());
 
 		@SuppressWarnings("unchecked")
 		final EventHandler<RecordArrayEvent>[] eventHandlers = new EventHandler[1];

src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java

@@ -70,7 +70,7 @@ class TCPReaderOneClient extends Thread {
 
 	@Override
 	public void run() {
-		final ByteBuffer buffer = ByteBuffer.allocateDirect(16 * 1024 * 1024);
+		final ByteBuffer buffer = ByteBuffer.allocateDirect(1024 * 1024);
 		try {
 			if (socketChannel.isConnected()) {
 				remoteAddress = ((InetSocketAddress) socketChannel.getRemoteAddress())