NIO編程之FileChannel讀寫鎖
一、FileChannel寫文件真的是并發(fā)安全的嗎?
比如說在一個(gè)jvm進(jìn)程內(nèi),是可以通過多個(gè)線程就使用一個(gè)FileChannel來寫,是線程安全的,那如果是多個(gè)jvm進(jìn)程呢?此時(shí)就沒辦法保證多線程按照順序來寫文件了,并發(fā)寫文件,還是可能會(huì)有問題的;
二、怎么避免多個(gè)jvm進(jìn)程寫文件導(dǎo)致的數(shù)據(jù)出錯(cuò)
FileChannel文件鎖,你可以對(duì)文件上鎖,共享鎖,獨(dú)占鎖,如果對(duì)文件是上共享鎖的話,此時(shí)你可以讀文件,別人也可以讀文件,別人也可以上共享鎖,如果是獨(dú)占鎖則只能由加鎖線程進(jìn)行文件讀寫,獨(dú)占鎖與共享鎖互斥;
底層是通過調(diào)用Linux的fnctl來從內(nèi)核對(duì)文件進(jìn)行加鎖來實(shí)現(xiàn)的;
三、demo
RandomAccessFile in = new RandomAccessFile("/Users/long/demo.txt", "rw");
FileChannel channel = in.getChannel();
// 對(duì)文件上獨(dú)占鎖,只能由加鎖線程進(jìn)行讀寫文件
FileLock lock = channel.lock(0, Integer.MAX_VALUE, false);
System.out.println("文件加獨(dú)占鎖成功");
// 對(duì)文件上共享鎖,允許多線程一起讀
/*FileLock lock = channel.lock(0, Integer.MAX_VALUE, true);
System.out.println("文件加共享鎖成功");*/
System.out.println(channel.read(ByteBuffer.allocate(100)));
// 釋放鎖
lock.release();
Thread.sleep(60 * 60 * 1000);
channel.close();
in.close();
四、Trylock 與lock方法
tryLock()是非阻塞式的,它設(shè)法獲取鎖,但如果不能獲得,例如因?yàn)槠渌恍┻M(jìn)程已經(jīng)持有相同的鎖,而且不共享時(shí),它將直接從方法調(diào)用返回。
lock()是阻塞式的,它要阻塞進(jìn)程直到鎖可以獲得,或調(diào)用lock()的線程中斷,或調(diào)用lock()的通道關(guān)閉。
五、共享鎖與獨(dú)占鎖區(qū)別
獨(dú)占鎖:也稱排它鎖,如果一個(gè)線程獲得一個(gè)文件的獨(dú)占鎖,那么其它線程就不能再獲得同一文件的獨(dú)占鎖或共享鎖,直到獨(dú)占鎖被釋放。其他線程不可讀寫;
共享鎖:如果一個(gè)線程獲得一個(gè)文件的共享鎖,那么其它線程可以獲得同一文件的共享鎖或同一文件部分內(nèi)容的共享鎖,但不能獲取排它鎖,其他線程可讀不可寫。