在Java中以循环方式运行线程

Question

我是Java中的多线程和同步的新手。我正在尝试实现一项任务，其中给了我5个文件，每个文件将由一个特定线程读取。每个线程应从文件读取一行，然后将执行转发到下一个线程，依此类推。当所有5个线程都读取第一行时，然后再次从线程1运行行号开始。文件1中的2，依此类推。

    Thread ReadThread1 = new Thread(new ReadFile(0));
    Thread ReadThread2 = new Thread(new ReadFile(1));
    Thread ReadThread3 = new Thread(new ReadFile(2));
    Thread ReadThread4 = new Thread(new ReadFile(3));
    Thread ReadThread5 = new Thread(new ReadFile(4));

    // starting all the threads
    ReadThread1.start();
    ReadThread2.start();
    ReadThread3.start();
    ReadThread4.start();
    ReadThread5.start();

并且在ReadFile（在run方法中实现Runnable的情况下，我正在尝试在bufferreader对象上进行同步。

        BufferedReader br = null;

            String sCurrentLine;
            String filename="Source/"+files[fileno];
            br = new BufferedReader(new FileReader(filename));

            synchronized(br)
            {

            while ((sCurrentLine = br.readLine()) != null) {
                int f=fileno+1;
                System.out.print("File No."+f);
                System.out.println("-->"+sCurrentLine);
br.notifyAll();
// some thing needs to be dine here i guess 
}}

需要帮忙

Answer 1

您缺少谜题的许多部分：

• 您尝试在每个线程本地的对象上进行同步。这可能没有任何效果，JVM甚至可以删除整个锁定操作。

• 您notifyAll没有匹配地执行wait;

• 缺少wait必须在 顶部 的的run方法，而不是在底部，你表示。

总的来说，恐怕此时修复您的代码超出了一个StackOverflow答案的范围。我的建议是首先使自己熟悉核心概念：Java中的锁的语义，它们如何与wait和互操作以及notify这些方法的精确语义。关于该主题的Oracle教程将是一个不错的开始。