Остановить нить сервера

public class Server {
 
    private static List<Message> lastMsg = new ArrayList<>();
 
    private static List<Socket> socketList = new ArrayList<>();
 
    public static void main(String[] args) throws IOException {
        for (int i = 0; i<10; i++)
            addMsg(new Message());
 
        ServerSocket socket = new ServerSocket(1234);
 
        System.out.println("Сервер стартовал");
        try {
 
            while (true) {
 
                Socket incoming = socket.accept();
 
                getSocketList().add(incoming);
 
                System.out.println("Есть подключение");
                Thread t = new Thread(new ThreadedHandler(incoming));
                t.start();
            }
        }finally {
            socket.close();
        }
    }
 
    public static void addMsg(Message msg){
        if(lastMsg.size()==10)
            lastMsg.remove(0);
        lastMsg.add(msg);
    }
 
    public static List<Message> getLastMsg(){
        return lastMsg;
    }
 
    public static List<Socket> getSocketList() {
        return socketList;
    }
}

public class ThreadedHandler implements Runnable {
 
    private Socket incoming;
    private ObjectOutputStream oos;
    private ObjectInputStream ois;
 
    public ThreadedHandler(Socket incoming) throws IOException {
        this.incoming = incoming;
 
    }
    @Override
    public void run(){
 
        try {
 
                Message msg = null;
 
                try{
 
                oos = new ObjectOutputStream(incoming.getOutputStream());
                ois = new ObjectInputStream(incoming.getInputStream());
                }catch (SocketException e){
                    System.out.println("Клиент отключился");
                    incoming.close();
                    Thread.currentThread().interrupt();
                }
 
                while (incoming.isConnected()) {
 
                    try {
                        msg = (Message) ois.readObject();
                    } catch (ClassNotFoundException e) {
                        e.printStackTrace();
                    }catch (SocketException se){
                        close();
                        System.out.println("Клиент отключился");
                        break;
 
                    }
 
                    if (msg.getMessage().equalsIgnoreCase("hi")){
                            for(Message m: Server.getLastMsg()){
                                oos.writeObject(m);
                                oos.flush();
                            }
                        }
                        else {
                            Server.addMsg(msg);
 
                            System.out.println(msg);
 
                            List<Socket> list = Server.getSocketList();
 
                            for (Socket socket : list) {
                                oos.writeObject(msg);
                                oos.flush();
                            }
                        }
                    }
 
 
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public synchronized void close() throws IOException {
 
        if (!incoming.isClosed()){
            try {
                ois.close();
                oos.close();
                incoming.close();
            }catch(IOException ignored){
                ignored.printStackTrace();
            }
        }
    }
}

public class Client {
    private Socket socket;
    private Scanner consoleInputReader;
    private ObjectOutputStream oos;
    ObjectInputStream ois;
    String login;
 
    public Client() throws IOException {
 
        socket = new Socket("localhost", 1234);
 
 
        consoleInputReader = new Scanner(System.in);
 
        Thread t = new Thread(new MsgReader());
        t.start();
    }
 
    public void run() throws IOException {
 
        System.out.println("Введите имя пользователя:");
 
        login = consoleInputReader.nextLine();
 
        oos = new ObjectOutputStream(socket.getOutputStream());
 
        oos.writeObject(new Message(login,"hi", socket));
        oos.flush();
 
        System.out.println("Введите сообщения");
 
            String str;
            try {
                while (!socket.isOutputShutdown()){
                    if (consoleInputReader.hasNext()) {
                        str = consoleInputReader.nextLine();// считывание строк из стандартного ввода
                        oos.writeObject(new Message(login, str, socket));// и отправка на сервер
                        oos.flush();
                    }
                }
            }finally {
                close();
            }
 
    }
    public synchronized void close() throws IOException {
 
        if (!socket.isClosed()){
            try {
                consoleInputReader.close();
                ois.close();
                oos.close();
                socket.close();
            }catch(IOException ignored){
                ignored.printStackTrace();
            }
        }
    }
 
    public static void main(String[] args) throws IOException {
        try{Client client = new Client();
            client.run();
        }catch (ConnectException e){
        System.out.println("Сервер недоступен");
        }
    }
 
    private class MsgReader implements Runnable{
 
        @Override
        public void run() {
            Message msg = null;
 
            try {
                ois = new ObjectInputStream(socket.getInputStream());
            } catch (IOException e) {
                System.out.println("Сеодинение с сервером прервалось");
                System.exit(1);
            }
            while (!socket.isInputShutdown()) {
                    try {
                        msg = (Message)ois.readObject();// считывание сообщений с сервера
                    } catch (IOException e) {
                        System.out.println("Соединение с сервером прервалось");
                        System.exit(1);
                        //break;
                    } catch (ClassNotFoundException e) {
                        e.printStackTrace();
                    }
                    System.out.println(msg.getLogin()+":"+msg.getMessage());
 
            }
        }
    }
}