java - 如何在并行线程中运行 2 个主要方法？

Question

我有以下两个类（为简单起见，仅包括主要方法）

public class UDPServer {

    public static void main(String[] args) throws IOException {
        int serverPort = 9876;
        DatagramSocket socket = new DatagramSocket(serverPort);
        byte[] buffer = new byte[1024];
        boolean isConnected = true;
        while (isConnected) {
            try {
                DatagramPacket request = new DatagramPacket(buffer, buffer.length);
                socket.receive(request);
                DatagramPacket reply = new DatagramPacket(
                        request.getData(),
                        request.getLength(),
                        request.getAddress(),
                        request.getPort()
                        );
                socket.send(reply);
            } catch (IOException ex) {
                isConnected = false;
                Logger.getLogger(UDPServer.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }

}

public class UDPClient {

    public static void main(String[] args) {
        String pathToQuery = getUserInput();
        List<Packet> queried = UDPServer.getQueriedServerDataTypes(pathToQuery);
        try {
            if (args.length < 1) {
                System.out.println("Usage: UDPCLient <msg> <server host name>");
                System.exit(-1);
            }

            // Create a new datagram socket
            DatagramSocket socket = new DatagramSocket();

            // Preferred IPv4 address (cmd: ipconfig/all)
            InetAddress host = InetAddress.getByName(args[0]);
            int serverPort = 9876;

            for (int i = 0; i < queried.size(); i++) {
                Packet dataType = queried.get(i);
                String requestFile = "data_type_request_v" + (i + 1) + ".txt";
                UDPServer.saveToFile(
                        dataType,
                        "Server request.",
                        requestFile
                );

                // Serialize Packet object to an array of bytes
                byte[] data = Tools.serialize(dataType);
                System.out.println("Sent: " + Arrays.toString(data));

                // Request datagram packet will store data query for the server
                DatagramPacket request = new DatagramPacket(
                        Objects.requireNonNull(data),
                        data.length,
                        host,
                        serverPort
                );

                // Send serialized datagram packet to the server
                socket.send(request);

                // The reply datagram packet will store data returned by the server
                DatagramPacket reply = new DatagramPacket(data, data.length);
                System.out.println("Reply: " + Arrays.toString(reply.getData()));

                // Acquire data returned by the server
                socket.receive(reply);

                // Store deserialized data in null Packet object.
                Packet read = (Packet) Tools.deserialize(data);
                System.out.println("Reading deserialized data...\n" + read.toString());
                String responseFile = "data_type_response_v" + (i + 1) + ".txt";
                UDPServer.saveToFile(
                        read,
                        "Server response.",
                        responseFile
                );

                boolean isResponseEqualRequest = UDPServer.isResponseEqualRequest(
                        requestFile,
                        responseFile
                );

                if (isResponseEqualRequest) {
                    System.out.println("Communication successful. Server response corresponds to the request.");
                } else {
                    System.out.println("Communication unsuccessful. Server response does not correspond to the request.");
                }
            }

            // Close the datagram socket
            socket.close();

        } catch (IOException | ClassNotFoundException ex) {
            Logger.getLogger(UDPClient.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

为了使 UDPClient 正常工作，UDPServer 必须在后台运行。我想在并行线程中运行 UDPServer.main()，一旦 UDPClient.main() 完成，线程也应该终止。

我怎么做？

标签： javamultithreading