Сервер на потоках

package com.company;
import java.io.*;
import java.net.*;
 
 
class Main
{
    public static void main(String[] args) throws IOException {
        String clientSentence;
        String capitalizedSentence;
        ServerSocket welcomeSocket = new ServerSocket(6789);
 
        while(true)
        {
            Socket connectionSocket = welcomeSocket.accept();
            BufferedReader inFromClient =
                    new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
            DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
            clientSentence = inFromClient.readLine();
            System.out.println("Received: " + clientSentence);
            capitalizedSentence = clientSentence.toUpperCase() + '\n';
            outToClient.writeBytes(capitalizedSentence);
        }
    }
}

ExecutorService es = Executors.newFixedThreadPool(32);

public class Main {
    public static void main(String[] args) throws IOException {
        ServerSocket welcomeSocket = new ServerSocket(6789);
        ExecutorService es = Executors.newFixedThreadPool(100);
 
        while(true)
        {
            Socket connectionSocket = welcomeSocket.accept();
            es.execute(() -> {
                try(BufferedReader input = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
                    DataOutputStream output = new DataOutputStream(connectionSocket.getOutputStream())) {
                    String clientSentence = input.readLine();
                    System.out.println("Received: " + clientSentence);
                    String capitalizedSentence = clientSentence.toUpperCase() + '\n';
                    output.writeBytes(capitalizedSentence);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
        }
    }
}

lambd_out.lam_1().forEach(i -> out1.println(i));