使用ThreadPool的多线程UDP服务器

Question

 
    public void run() {
                

Answer 1

您不需要自己的队列。ExecutorService有一个任务队列。我还建议不要每次打开一个新的套接字，因为你可以重复使用它们。

结果代码可能大致如下所示。

public void run() {
    ExecutorService tpes = Executors.newFixedThreadPool(10);
    int server_port = 8767;
    DatagramSocket s = null;
    try {
        s = new DatagramSocket(server_port);
        while (true) {
            byte[] message = new byte[1024];
            DatagramPacket p = new DatagramPacket(message, message.length);
            try {
                s.receive(p);
                tpes.execute(new RequestHandler(p));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    } catch (SocketException e) {
        e.printStackTrace();
        System.out.println("Socket excep");
    } finally {
        if (s != null) s.close();
    }
}

RequestHandler将在10个线程中的一个线程上运行，如果收到的请求超过10个线程所能处理的请求，则在Executor中将有一个挂起的RequestHandler任务队列。