Блокировка потоков при массовой рассылке сообщений

    public void sendBroadcastMessage(ServerToClientThread fromUser, Message message){
        try {
            if (broadcastLock.tryLock(WAIT_SEC, TimeUnit.SECONDS)) {
                isBroadcastLocked = true;
                for (Map.Entry<String, ServerToClientThread> user : users.entrySet()) {
            //самому себе не отсылаем свое же сообщение
                    if (user.getValue() != fromUser) {
                        ServerToClientThread userTo = user.getValue();
                        userTo.sendMessage(message);
                    }
                }
 
                String command = message.getCommand();
        //в лог сохраняем все сообщения, кроме тех что были направлены другому пользователя напрямую
                if (!ServerSettings.DIRECT_TO.equals(command)) {
                    addMessage(message.getMessage());
                }
            }
        } catch (Exception e) {
            System.out.println("TryLock error from: " + fromUser.getUser_name() + ". " + e);
        } finally {
            if (isBroadcastLocked) {
                broadcastLock.unlock();
                isBroadcastLocked = false;
            }
        }
    }

    public void sendBroadcastMessage(ServerToClientThread fromUser, Message message) {
        try {
            if (broadcastLock.tryLock(WAIT_SEC, TimeUnit.SECONDS)) {
                try {
                    for (Map.Entry<String, ServerToClientThread> user : users.entrySet()) {
    
                        if (user.getValue() != fromUser) {
                            ServerToClientThread userTo = user.getValue();
                            userTo.sendMessage(message);
                        }
                    }
                    String command = message.getCommand();
                    if (!ServerSettings.DIRECT_TO.equals(command)) {
                        addMessage(message.getMessage());
                    }
                } finally {
                    broadcastLock.unlock();
                }
            }
        } catch (Exception e) {
            System.out.println("TryLock error from: " + fromUser.getUser_name() + ". " + e);
        }
    }

    public boolean sendMessage(Message message){
        try {
            out.writeObject(message);
            out.flush();
            out.reset();
            return true;
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("Sending message error: "+ e);
            return false;
        }
    }

in = new ObjectInputStream(socket.getInputStream());
out = new ObjectOutputStream(socket.getOutputStream());