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

Question

我已经阅读了很多帖子，其中谈到了使用 JavaME 同时读取和写入文件不。我有一个特殊的用例场景，其中我的日志文件（可能是完整文件或只是文件的一部分）定期上传到服务器。这必须在不妨碍应用程序在同一文件中的当前日志记录的情况下继续进行。

代码示例如下：

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

出现不希望的结果： 读写线程显示正在运行的读写操作。读取线程正在从写入线程已写入的位置读取。我在这段代码中没有遇到任何异常，但结果是不希望的。我也尝试过同步读写流，但那是抛出IllegalMonitorStateException

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

任何帮助/指针有用吗？

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

Answer 1

我将解决这个问题：

Present Undesired Result：读写线程显示正在运行的读写操作。读取线程正在从写入线程已写入的位置读取。我在这段代码中没有遇到任何异常，但结果是不希望的。我也尝试过同步读写流，但那是抛出IllegalMonitorStateException。

如果您已使用监视器同步访问，即读取器调用someObject.wait() 而写入器调用someObject.notify()，请记住您必须将这些调用包装在someObject 上的同步块中：

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


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

这就是IllegalMonitorStateException的原因。

Answer 2

您的第一个问题是您在写入数据之前设置了writtenCharsLen。如果您的读取线程在写入线程实际写入它之前看到它是非零的，那么您就有问题了。写入后移动writtenCharsLen = str.length。

我在您的示例中看到的另一个问题是线程永远不会产生控制权。他们会占用 CPU。