場景：多個地方同時向一個檔案讀寫據，如何保持操作互斥性，即一次只能一個操作（比如讀或寫）進行。

我們希望在一個執行緒在操作某個檔案的時候,其他執行緒不能對該檔案進行讀或寫操作,要怎麼才能實現呢?利用java提供的synchronized似乎無法完成,因為每個執行緒是在程式中動態丟擲的.鬱昧了一天之後,我終於找到了一個解決辦法,就是利用java.nio包中的FileChannel對檔案進行加鎖.

具體實現方法如下:

1.寫檔案的執行緒

package chb.thread; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.nio.channels.FileChannel; import java.nio.channels.FileLock; import java.util.Calendar; /** * @author chb */ public class Thread_writeFile extends Thread{ public void run(){ Calendar calstart=Calendar.getInstance(); File file=new File("D:/test.txt"); try { if(!file.exists()) file.createNewFile(); //對該檔案加鎖 FileOutputStream out=new FileOutputStream(file,true); FileChannel fcout=out.getChannel(); FileLock flout=null; while(true){ flout=fcout.tryLock(); if(flout!=null){ break; } else{ System.out.println("有其他執行緒正在操作該檔案，當前執行緒休眠1000毫秒"); sleep(100); } } for(int i=1;i<=1000;i++){ sleep(10); StringBuffer sb=new StringBuffer(); sb.append("這是第"+i+"行，應該沒啥錯哈 "); out.write(sb.toString().getBytes("utf-8")); } flout.release(); fcout.close(); out.close(); out=null; } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } Calendar calend=Calendar.getInstance(); System.out.println("寫檔案共花了"+(calend.getTimeInMillis()-calstart.getTimeInMillis())+"秒"); } }

2.讀檔案的執行緒

package chb.thread; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.nio.channels.FileChannel; import java.nio.channels.FileLock; import java.util.Calendar; /** * @author chb */ public class Thread_readFile extends Thread{ public void run(){ try { Calendar calstart=Calendar.getInstance(); sleep(5000); File file=new File("D:/test.txt"); //給該檔案加鎖 FileInputStream fis=new FileInputStream(file); FileChannel fcin=fis.getChannel(); FileLock flin=null; while(true){ flin=fcin.tryLock(0,Long.MAX_VALUE,true); if(flin!=null){ break; } else{ System.out.println("有其他執行緒正在操作該檔案，當前執行緒休眠1000毫秒"); sleep(1000); } } byte[] buf = new byte[1024]; StringBuffer sb=new StringBuffer(); while((fis.read(buf))!=-1){ sb.append(new String(buf,"utf-8")); buf = new byte[1024]; } System.out.println(sb.toString()); flin.release(); fcin.close(); fis.close(); fis=null; Calendar calend=Calendar.getInstance(); System.out.println("讀檔案共花了"+(calend.getTimeInMillis()-calstart.getTimeInMillis())+"秒"); }catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } } }

3.分別啟用兩個執行緒

Thread_writeFile thf3=new Thread_writeFile(); Thread_readFile thf4=new Thread_readFile(); thf3.start(); thf4.start(); 

4.結果分析

以上程式在對一個檔案執行寫操作前,先對該檔案加鎖,這樣其他執行緒就不能再對該檔案操作,等該執行緒的寫操作結束,釋放資源,其他執行緒才可以繼續對該檔案執行相應的讀寫操作.

可是,鬱昧的是,這段程式在windows下可以正確執行,在linux下卻無效.根據<Thinking in Java>上的觀點是:對獨佔鎖或者共享鎖的支援必須由底層的作業系統提供。