1

java : jdk9.01
os : linux Red Hat 4.8.5-11

Javaのコードで他のプログラムの出力するファイルのチェックを数秒毎にチェックし、
存在を確認できたら次に進むというコードを書こうとしています。

int n = 0;
boolean flag = false;
while (flag == false) {
    TimeUnit.SECONDS.sleep(waitsec);
    flag = Files.exists(path);
     n += 1;
     if (n > limit) {
         System.out.println("limit over");
     }
}

上のような感じで書いているのですが
ところがファイルが出力されているはずなのにflagがtrueになりません。
trueが帰ることもあるのですがタイミングがバラバラだったりします。
lsコマンドなどで自分で存在を確認すると
そのとたんにFiles.existsでもtrueが帰ります。

理由は分かりませんが、シュレディンガーの猫のような感じです。
自分で見つけた解決策としてはFiles.findを使えばなんとかなるのですが
Files.existsがなぜうまく作用しないのか理由がしりたいと考えています。

原因がわかる方がいましたら、ご教授お願いします。

6
  • 原因については分かりませんが、他のプログラムが作成するファイルの存在をチェックするのでしたら、Java7 から導入された WatchService を利用してみてはどうでしょうか。File system events with Java 7
    – user39889
    Commented 2018年9月25日 9:28
  • 本題と関係ないかも知れないですが、環境条件に記載の「Red Hat 4.8.5-11」は誤記でしょうか? (Java9が動作する環境にしてはバージョンが古すぎるように見えるため)
    – user20098
    Commented 2018年9月25日 12:31
  • WatchServiceを試してみたのですが、
    – pikopiko
    Commented 2018年9月26日 0:28
  • なぜか自分の監視したいファイル出力は反応してくれませんでした・・・。 LinuxのVer.については誤記ではありません。自分もあまりハードに詳しくないためよく知らないのですが、LinuxのVer.が古いとよくないということですかね、OSのVer.は自分ではどうにもならないのでJavaのVer.を下げた方がいいかもないですね
    – pikopiko
    Commented 2018年9月26日 0:34
  • 1
    WatchServiceが監視できるのはあくまで自身のPCが書き込んだイベントのみのようです。自分のケースの場合、ネットワークドライブ上の他のPCから出力されたファイルの監視だったのでWatchServiceは使えないようです。
    – pikopiko
    Commented 2018年9月26日 0:46

2 件の回答 2

3

ファイル出力側のプログラムでファイル出力をフラッシュしてない場合、タイミングよっては出力がバッファリングされた状態となり、ディスクに書き込まれてないので、他のプログラムからは読めないのかもしれません。

Cだとfflushやfsyncなどを使って明示的に書き込みをフラッシュしてみると変化があるかもしれません。また、Javaだと、PrintWriterなどのFlushableインターフェースの実装で flush() を呼び出すと書き込みがフラッシュされると思います。

2

ネットワークドライブ上の他のPCから出力されたファイルの監視

という条件から推測すると、NFS領域を非同期モードで使用しているため、他のPCで書き出した(作成した)ファイルが同期的に見えないため、と考えます。

NFSサーバのエクスポートオプションに「sync」を指定する、加えてNFSクライアントのマウントオプションにも「sync」を指定することで解消すると思います。


なお、OSは「RHEL4」ということですが、Java9の動作条件によると、RHEL6以上とのことですので、Java9は見送られたほうがよいかと思います。

また、RHEL4のkernelは2.6.9ですので、inotify-java APIも動作しないかと思います。(inotify-javaのサイトには、2.6.13以降が必要、とあるため)

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。