在 JavaFx 中管理至少三个线程

Question

我正在尝试将我的服务器配置为管理至少 3 个客户端，但是当我这样做时，即使在连接第一个客户端之前，我也会收到内存不足错误。我该如何改进它？在ThreadedEchoHandler() 中，我接受了客户端的请求和包含服务器必须做的所有事情的运行方法。

public void initModel() throws IOException {
    contenutoTextArea.append("Waiting for connections\n");
    textarea.setText(contenutoTextArea.toString());
    s = new ServerSocket(5000);
    while (true) {
        Runnable r = new ThreadedEchoHandler();
        new Thread(r).start();
    }
}

编辑：ThreadedEchoHandler 的开始：

lass ThreadedEchoHandler implements Runnable {

    private Socket incoming;

    private String nomeAccount = "";

    public void run() {
        try {
            incoming = s.accept();
        } catch (IOException ex) {
            System.out.println("Unable to accept requests");
        }
    }

Answer 1

您应该在发生while 循环的同一线程中执行accept，然后在接受新的连接后，启动一个新线程：

while (true) {
    Socket incoming = s.accept();
    Runnable r = new ThreadedEchoHandler(incoming);
    new Thread(r).start();
}

并修改ThreadEchoHandler 以从外部获取其Socket：

class ThreadedEchoHandler implements Runnable {
    final private Socket incoming;
    private String nomeAccount = "";

    ThreadedEchoHandler(Socket incoming) {
        this.incoming = incoming;
    }

    public void run() {
        // do stuff
    }
}

当然你可以用各种方式组织它，比如ThreadedEchoHandler 可以从构造函数启动它的线程，甚至也可以执行accept，但同样，它必须发生在开始之前主题：

class ThreadedEchoHandler implements Runnable {
    final private Socket incoming;
    private String nomeAccount = "";

    ThreadedEchoHandler(ServerSocket serv) throws IOException {
        incoming = serv.accept();
        new Thread(this).start();
    }

    public void run() {
        // do stuff
    }
}

那么循环可能是这样的：

while (true) new ThreadedEchoHandler(s);