我正在开发磁盘缓存(多线程)。缓存可以同时拥有多个用户。这就是为什么我可以写一些规则:
1) 客户端读取文件时,缓存无法编辑(或删除)文件。
2) 当缓存正在编辑文件时,客户端应该等待编辑结束(并且在读取文件之后)。
我需要在 java 的帮助下组织这个锁策略。
我阅读了有关 synchronizatioan(同步块和 java.util.concurrent.Locks)的信息,据我所知,它在这里无济于事。
我试图理解 FileLock。但是当客户端读取文件时,缓存锁可以中止读取。如果客户端在读取之前会锁定文件,那么客户端读取的序列就会很长。我需要建议如何组织它(也许是另一种方式)。
更新
public void write(InputStream is) throws FileNotFoundException, IOException {
File file = new File("path");
try (FileOutputStream fos = new FileOutputStream(file);
FileChannel filechannel = fos.getChannel();
FileLock lock = filechannel.lock(0, Long.MAX_VALUE, false)) {
// writing....
}
}
public void read(OutputStream osToClient) throws IOException {
File file = new File("path");
try (FileInputStream fis = new FileInputStream(file);
FileChannel filechannel = fis.getChannel();
FileLock lock = filechannel.lock(0, Long.MAX_VALUE, true)) {
IOUtils.copy(fis, osToClient);
}
}