java - 使用 TCP/IP 套接字的多线程

Question

我正在 Java 中处理套接字。问题是我们正在从硬件设备获取信号，如果在一定时间间隔(200ms)后未扫描设备，则会挂起。所以我需要加快这个操作。如何使用多任务处理来加速以下代码。

此处的行数通常在 250 范围内。

    sock = new Socket("localhost", def.PORT);

    OutputStream outStream = sock.getOutputStream();
    DataOutputStream outDataStream = new DataOutputStream(outStream);
    /**************** Start Command for CystometryEMG *****************/
    outDataStream.writeInt(size);
    outDataStream.writeInt(command);
    outDataStream.writeBytes(msg);

    InputStream input = new BufferedInputStream(sock.getInputStream());
    reader = new DataInputStream(input);

    sock.setSoTimeout(def.SOCKET_READ_TIME_OUT);
    if (sock.isClosed())
        return;
    size = reader.readInt();
    command = reader.readInt();
    errorCode = reader.readInt();
    NoofCols = reader.readInt();
    NoOfRows = reader.readInt();

    /************** Now get the input from the device *************/

    for (int i = 0; i < NoOfRows; i++)
        arrPb[i] = reader.readDouble();

    for (int i = 0; i < NoOfRows; i++)
        arrPv[i] = reader.readDouble();

    for (int i = 0; i < NoOfRows; i++)
        arrV[i] = reader.readDouble();

    for (int i = 0; i < NoOfRows; i++)
        arrVn[i] = reader.readDouble();

    sock.close();

Answer 1

将扫描设备与所有其他操作分离。将其分成两个线程。一个线程(前端)除了扫描设备并将接收到的数据保存到队列中之外不处理任何事情。该线程应以最高优先级运行。第二个线程(后端)从队列中获取数据，并在闲暇时用它做任何你想做的事情。您可能需要多个后端线程，在完成此工作后，您需要调整后端线程的数量，以确保您处理请求的速度比从设备接收请求的速度快，否则您的队列将变得太大。

但请注意，Java 通常不是实时语言，即使使用专用线程，前端线程也可能需要更多时间来安排您可能喜欢的时间。您可以在网络上搜索“realtime java”，看看现有的实时 JVM 是否可以帮助您。

无论如何，不​​要考虑在低于 4 核的 CPU 上运行它