TCPClient Test

package test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.concurrent.*;
import my.jutils.Utils;
import my.jutils.net.*;
import my.jutils.services.BackgroundThreadFactory;
import org.slf4j.*;

/**
 *
 * @author Erieze
 */
public class TCPClientTest {

    private static final Logger LOGGER = LoggerFactory.getLogger(TCPClientTest.class);

    private final ScheduledExecutorService readd;
    private final ScheduledExecutorService sendd;
    private final TCPClient client1;

    public TCPClientTest() {
        this.readd = Executors.newSingleThreadScheduledExecutor(new BackgroundThreadFactory("Reader-Service"));
        this.sendd = Executors.newSingleThreadScheduledExecutor(new BackgroundThreadFactory("Sender-Service"));
        this.client1 = new TCPClient("localhost", 5432);
    }

    private void execute() {
        client1.execute(true);
        readd.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                LOGGER.info("Reading response from client1: {}", client1.readln());
            }
        }, 0, 5, TimeUnit.SECONDS); // Every 5 seconds
        sendd.scheduleAtFixedRate(new Runnable() {

            @Override
            public void run() {
                final BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
                try {
                    LOGGER.info("Enter: ");
                    client1.write(br.readLine());
                } catch (IOException e) {
                    LOGGER.error("Cause: {}", e.toString(), e);
                }
            }
        }, 0, 1, TimeUnit.SECONDS);
    }

    public static void main(String[] args) {
        Utils.log4j();
        new TCPClientTest().execute();
    }

}