将当前线程休眠特定时间

Question

我正在尝试编写小型多线程程序。我想通过多个线程在不同的帧时间运行相同的进程。

我创建了一个输入文件，其中我对同一个进程有不同的名称，并且该进程应该运行的毫秒数。

T1|1000
T2|2000
T3|3000
T4|4000
T5|5000

Java 程序

package Test;

import java.io.*;

public class MultiProcess {


    public static void main(String[] args) throws IOException {

        BufferedReader br = new BufferedReader(new FileReader("/home/maria/Process.txt"));

        String st;
        while ((st = br.readLine()) != null) {

            String[] records = st.split("|");
            Thread tr = new ProcessExecution(records[0], Integer.parseInt(records[1]));
            tr.start();
        }

        br.close();
    }

    static class ProcessExecution extends Thread {

        int threadTime = 0;
        String processName;

        ProcessExecution(String processName, int x) {
            this.threadTime = x;
            this.processName = processName;

        }

        @Override
        public void run() {

            try {
                System.out.println("ProcessName: " + this.processName);
                Thread.sleep(this.threadTime);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

        }

    }

}

在上面的代码中，ProcessExecution 有不同的名字，它们来自文件，并且想要让当前运行的线程休眠特定的时间段，这也是来自文件。

我得到了这个奇怪的输出

ProcessName: T
ProcessName: T
ProcessName: T
ProcessName: T
ProcessName: T

什么是错以及如何实现？

谢谢

更新

似乎所有线程都在同时完成。它应该保持活跃到来自文件的毫秒数。怎么了？

Answer 1

“|”是一个特殊字符，需要转义。 将String[] records = st.split("|"); 替换为String[] records = st.split("[|]"); 即可。这里解释： https://javarevisited.blogspot.com/2017/01/how-to-split-string-based-on-delimiter-in-java.html

您也可以将其替换为String[] records = st.split("\\|");

Answer 2

当你这样做时

String[] records = st.split("|");

记录数组将有

0 = "T"
1 = "1"
2 = "|"
3 = "1"
4 = "0"
5 = "0"
6 = "0"

你应该这样做

String[] records = st.split("\\|");

作为 |是特殊字符

Answer 3

正如其他人所指出的，您需要使用st.split("\\|") 来获取 T1 而不是 T。

根据以正确顺序打印的正确值，例如，您希望首先休眠 1000 毫秒，然后才打印一条消息：

        try {
            Thread.sleep(this.threadTime);
            System.out.println("ProcessName: " + this.processName);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

Answer 4

你需要逃离管道：

st.split("\\|");

与我的 cmets 一起使用，这里有一个更好的整体解决方案：

public class MultiProcess {
    private static final Logger LOGGER = Logger.getAnonymousLogger();
    public static void main(String[] args) throws IOException, InterruptedException {

    String [] values = new String[] {"T1|1000", "T2|2000", "T3|3000", "T4|4000", "T5|5000"}; 
    ExecutorService executor = Executors.newFixedThreadPool(5);
    for (String val : values) {
        String[] records = val.split("\\|");
        executor.execute(new ProcessExecution(records[0], Integer.parseInt(records[1])));
    }
    executor.shutdown();
}

static class ProcessExecution implements Runnable {

    int threadTime = 0;
    String processName;

    ProcessExecution(String processName, int x) {
        this.threadTime = x;
        this.processName = processName;
    }

    @Override
    public void run() {
       try {
           Thread.sleep(this.threadTime);
            LOGGER.info(String.format("ProcessName: %s", processName));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }

}

}