如何通知另一个线程文件被修改

Question

我是java多线程编程的新手。我知道它可以通过线程通信来完成，但我不知道如何继续。我不知道如果在文件中进行了一些更改，一个线程将如何通知另一个线程。问题在下面提到。

我有一个逗号分隔的文件，其中写入了一些行。我希望从我的主线程启动两个线程。csv文件可能会附加到外部/手动。如果csv文件中做了一些更改，其中一个线程将通知第二个线程，第二个线程将逐行并发读取该文件并执行一些任务。

谢谢

Answer 1

您创建两个线程，在它们的run方法中，它们都使用一个Object作为线程等待和通知信号。

第一个线程（T1）将在对象上同步并等待它。第二个线程（T2）将在对象上同步，对其执行某些操作，并发出通知。

以下片段应该会给你一些想法...（请忽略无休止的循环和糟糕的异常处理，这只是为了便于理解而表达的想法）。

public class IdeaOfThreadingWithWaitAndNotify {

    public static void main(String[] args)  {
        File f = new File("grow.txt");
        if(!f.exists()) {
            try {
                f.createNewFile();
                Thread appenderThread = new Thread(new FileAppender(f));
                Thread checkerThread = new Thread(new FileSizeCounter(f));
                appenderThread.start();
                checkerThread.start();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static class FileAppender implements Runnable {
        private File file;
        private FileOutputStream fos;
        public FileAppender(File file) throws FileNotFoundException {
            super();
            this.file = file;
            fos = new FileOutputStream(file);
        }
        public void run() {
            while(true) {
                synchronized (file) {                   
                    try {
                        fos.write("Appended... ".getBytes());
                        fos.flush();
                        file.notify();
                        Thread.sleep(1000);
                    } catch (IOException e) {
                    } catch (InterruptedException e) {
                    }
                }
            }
        }

    }

    public static class FileSizeCounter implements Runnable {
        private File file;
        public FileSizeCounter(File file) {
            super();
            this.file = file;
        }
        public void run() {
            while(true) {
                synchronized (file) {
                    try {
                        file.wait();
                    } catch (InterruptedException e) {
                    }
                    System.out.println("File changed .. now size is " + file.length());
                    // you can do other stuff with the file...
                }
            }
        }
    }
}

您可以看到，在两个线程之间，它们共享同一个“文件”实例，并将其用作等待和通知信号。调用wait的对象将在那里停止其执行流，直到另一个线程对其调用notify。然后等待的线程可以继续。

我希望这有帮助。

Answer 2

你可以使用java。尼奥。文件WatchService可用于此目的
参考教程

从链接：-

Watch Service API专为需要通知文件更改事件的应用程序而设计。它非常适合任何可能有许多打开文件并需要确保文件与文件系统同步的应用程序，例如编辑器或IDE。它也非常适合监视目录的应用程序服务器，可能等待. jsp或. jar文件删除以部署它们。