java - 如何同时读取和写入数据到同一个文件

Question

我读过许多帖子，其中谈到使用 JavaME 同时NOT 读取和写入文件。我有一个特殊的用例场景，我的日志文件(可能是完整文件或文件的一部分)定期上传到服务器。这必须继续进行，而不会妨碍同一文件中应用程序的当前日志记录。

代码示例如下:

boolean writing = true;
boolean reading = true;
void main() {
    new Thread("THREAD-FILE-READ") {
        public void run() {
            InputStream instream = getFileInStream();
            if (null != instream) {
                while (reading) {
                    try {
                        try {
                            synchronized(READ_LOCK) {
                                READ_LOCK.wait();
                            }
                        } catch (InterruptedException ex) {
                            ex.printStackTrace();
                        }

                        if (writtenCharsLen > 0) {
                            byte[] bytes = new byte[writtenCharsLen];
                            instream.read(bytes, 0, writtenCharsLen);
                            System.out.println("Read="+new String(bytes));
                            bytes = null;
                            writtenCharsLen = 0;
                        }
                    } catch (IOException ioe) {
                        ioe.printStackTrace();
                    }
                }
            }
            closeStream(instream);
        }
    }.start();

    new Thread("THREAD-FILE-WRITE") {
        public void run() {
            OutputStream outstream = getFileOutStream();
            if (null != outstream) {
                while (writing) {
                    try {
                        byte[] str = randomString();
                        if (null != str) {
                            writtenCharsLen = str.length;
                            System.out.println("Write=" + new String(str));
                            outstream.write(str);
                            str = null;
                        }
                    } catch (IOException ex) {
                        ex.printStackTrace();

                    } finally {
                        notifyReadStream();
                    }

                    try {
                        synchronized(WRITE_LOCK) {
                            WRITE_LOCK.wait();
                        }
                    } catch (InterruptedException ex) {
                        ex.printStackTrace();
                    }
                }
            }
            closeStream(outstream );
        }
    }.start();

}

void notifyReadStream() {
    try {
        synchronized (READ_LOCK) {
            READ_LOCK.notify();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

void notifyWriteStream() {
    try {
        synchronized (WRITE_LOCK) {
            WRITE_LOCK.notify();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

在上面的代码中，我将用对网络 IO 方法的适当调用替换 sop-read 和 sop-write。

PS:由于这段代码将运行多个文件和多个设备，我需要尽可能压缩修改以保持运行时堆尽可能低。此外，这段代码将一直运行到应用程序生命周期，因此不考虑在中间关闭和打开文件。

出现不希望的结果:读取和写入线程显示正在运行用于读取和写入的 sop。读取线程从写入线程写入的位置开始读取。我在此代码中没有遇到任何异常，但结果是不希望的。我也尝试过同步读写流，但那是抛出 IllegalMonitorStateException

预期结果:流的读取必须在写入流完成后触发，并且读取线程必须能够从文件中的任何位置读取。

有什么帮助/指点有用吗？

编辑: 我能够使用不同的显示器同步读取和写入流，但我仍然觉得，使用单个显示器我可以做得更好。稍后会尝试。

Answer 1

我会解决这个问题:

出现意外结果:读取和写入线程显示正在运行读取和写入的 sop。读取线程从写入线程写入的位置开始读取。我在此代码中没有遇到任何异常，但结果是不希望的。我也尝试过同步读取和写入流，但会抛出 IllegalMonitorStateException。

如果您使用监视器同步访问，即读取器调用 someObject.wait() 并且写入器调用 someObject.notify()，请记住您必须包装someObject 上的同步块(synchronized block)中的这些调用:

synchronized(someObject) {
    someObject.wait();
}


synchronized(someObject) {
    someObject.notify();
}

这就是 IllegalMonitorStateException 的原因。