package tcpproxy;

import tcpproxy.dispatcher.Dispatcher;
import tcpproxy.dispatcher.DispatcherSameThread;

import java.io.IOException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.util.concurrent.ExecutionException;

public class Runner {

    public static void main(final String[] args) throws IOException, ExecutionException, InterruptedException {

        final ServerSocketChannel server = ServerSocketChannel.open();
        server.socket().bind(new java.net.InetSocketAddress(7000));
        server.configureBlocking(false);

        final Selector selector = Selector.open();
        server.register(selector, SelectionKey.OP_ACCEPT);

        final Dispatcher dispatcher = new DispatcherSameThread(selector);
//        final Dispatcher dispatcher = new DispatcherThreadPool(selector, args[0]);
//        final Dispatcher dispatcher = new DispatcherShareSelector(selector);
        dispatcher.start();
    }

}

@@ -443,26 +443,24 @@
 xception %7B%0D%0A
-%0D%0A
         fina
@@ -825,174 +825,8 @@
 );%0D%0A
-//        final Dispatcher dispatcher = new DispatcherThreadPool(selector, args%5B0%5D);%0D%0A//        final Dispatcher dispatcher = new DispatcherShareSelector(selector);%0D%0A
     

Clear code.