<commit_before>package com.tcp.client;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.Date;

public class TCPClient {

    public static void main(String args[]) {
        try {

            String message, response;
            Socket socket = new Socket("172.16.58.3", 80);

            DataOutputStream output = new DataOutputStream(socket.getOutputStream());
            BufferedReader server = new BufferedReader(
                    new InputStreamReader(socket.getInputStream())
            );

            BufferedReader reader = new BufferedReader(
                    new InputStreamReader(System.in)
            );
            message = reader.readLine() + System.lineSeparator();


            output.writeBytes(message);
            response = server.readLine();

            System.out.println("[" + new Date() + "] Received: " + response);
            socket.close();

        } catch (IOException e) {
            e.printStackTrace();
        }


    }

}<commit_msg>Update TCPClient.java<commit_after>package com.tcp.client;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TCPClient {

	private static class TCPWorker implements Runnable {

		private Socket socket;
		private String IPaddress;
		private int port;
		private int id;

		public TCPWorker(Socket socket, String address, int port, int id) {
			this.socket = socket;
			this.IPaddress = address;
			this.port = port;
			this.id = id;
		}

		@Override
		public void run() {

			try {
				for (int i = 0; i < 300; i++) {
					String message, response;
					DataOutputStream output = new DataOutputStream(socket.getOutputStream());
					BufferedReader server = new BufferedReader(new InputStreamReader(socket.getInputStream()));

					message = "HELLO" + System.lineSeparator() + IPaddress + " " + port + System.lineSeparator() + id + System.lineSeparator();

					output.writeBytes(message);
					response = server.readLine();

					System.out.println("[" + new Date() + "] Received: " + response);
				}
				socket.close();

			} catch (IOException e) {
				e.printStackTrace();
			}

		}

	}

	public static final int N = 10;
	public static ExecutorService TCP_WORKER_SERVICE = Executors.newFixedThreadPool(N);

	public static void main(String args[]) {
		try {
			int id;
			Socket socket = new Socket(args[0], Integer.parseInt(args[1]));
			for (id = 1; id <= 10; id++)
				TCP_WORKER_SERVICE.submit(new TCPWorker(socket, args[0], Integer.parseInt(args[1]), id));

		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}
{'fraction_non_alphanumeric': 0.11649122807017544, 'fraction_numerical': 0.008070175438596491, 'mean_word_length': 2.9707520891364902, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 1, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3697612', 'n_tokens_mistral': 913, 'n_tokens_neox': 799, 'n_words': 204}