Многопоточность и сокеты

import java.net.*;
import java.io.*;
 
public class soc {
    public static void main(String args[]){
        try(Socket s = new Socket(InetAddress.getLocalHost(), 1024)){
        OutputStream out = s.getOutputStream();
        while(true){
            String s1 = new BufferedReader(new InputStreamReader(System.in)).readLine();
            byte b[] = s1.getBytes();
            out.write(b);
        }
        }catch(IOException e){
            System.out.println("Сервер недоступен");
        }
    }
}

import java.net.*;
import java.io.*;
 
public class sos {
    public static void main(String args[]){
        try(ServerSocket s = new ServerSocket(1024)){
            while(true){
                Socket s2 = s.accept();
                s2.getOutputStream().write("Соединение установлено".getBytes());
                new thread(s2).run();       
            }
        }catch(IOException e){
            System.out.println("Connection aborted!");
        }
    }
}

import java.net.*;
import java.io.*;
 
public class thread implements Runnable{
    Socket s;
    
    thread(Socket s){
        this.s = s;
    }
    
    public void run(){
        try(InputStream in = s.getInputStream()){
            s.getOutputStream().write("Метод run класса thread".getBytes());
            while(true)
                System.out.print((char)in.read());
        }catch(IOException e){
            System.out.println("thread exception");
        }
    }
}

new thread(s2).run();

new thread(s2).run();