請教：關(guān)于RandomAccessFile阻塞ScheduledExecutorService的問題

panghaoyu

大家好，

我想實現(xiàn) 讀一個正在動態(tài)增長的日志 的功能，下面第一段代碼本夠用了，可惜 那個日志還會不定時自動 歸檔（滾動，也就是 *.log 變 *.log1 ,*.log1變 *.log2 ，類推）

已經(jīng)打開的 RandomAccessFile  仍然盯著最早關(guān)聯(lián)的文件，無法識別關(guān)聯(lián)到新生成的 *.log,

所以我修改了這段代碼，就是下面第二段代碼

新的問題是：

程序已運行到 randomFile.close(); 處就卡住 ，不能進行了

想知道原因，我對多線程了解不多，請大家指點。謝謝了

final RandomAccessFile randomFile = new RandomAccessFile(logFile, "rw");       
ScheduledExecutorService exec = Executors.newScheduledThreadPool(1);
                exec.scheduleWithFixedDelay(new Runnable() {
                        public void run() {
                                try
                                {
                                        RandomAccessFile randomFile = new RandomAccessFile(logFile, "rw");

                                        randomFile.seek(lastTimeFileSize);
                                        String tmp = "";


                                        while ((tmp = randomFile.readLine()) != null)
                                        {
                                                   //do something
                                        }
                                                       
                                       
                                }
                                catch (IOException e)
                                {
                                        throw new RuntimeException(e);
                                }



        ScheduledExecutorService exec = Executors.newScheduledThreadPool(1);
                exec.scheduleWithFixedDelay(new Runnable() {
                        public void run() {
                                try
                                {
                                        RandomAccessFile randomFile = new RandomAccessFile(logFile, "rw");

                                        randomFile.seek(lastTimeFileSize);
                                        String tmp = "";


                                        while ((tmp = randomFile.readLine()) != null)
                                        {
                                                   //do something
                                        }
                                        //程序會停止到這個位置，無法進行下去，沒有報任何異�；蝈e誤
                                        //如果把 close（） 給刪除掉，程序就可以正常往下運行了
                                        randomFile.close();                                                               
                                       
                                }
                                catch (IOException e)
                                {
                                        throw new RuntimeException(e);
                                }
                        }
                }, 0, 10, TimeUnit.SECONDS);

ddd010

我想你的問題應(yīng)該在這段代碼的synchronized里面。

1. 
   
2.     /**
   
3.      * Closes this random access file stream and releases any system
   
4.      * resources associated with the stream. A closed random access
   
5.      * file cannot perform input or output operations and cannot be
   
6.      * reopened.
   
7.      *
   
8.      * <p> If this file has an associated channel then the channel is closed
   
9.      * as well.
   
10.      *
    
11.      * @exception  IOException  if an I/O error occurs.
    
12.      *
    
13.      * @revised 1.4
    
14.      * @spec JSR-51
    
15.      */
    
16.     public void close() throws IOException {
    
17.         synchronized (closeLock) {
    
18.             if (closed) {
    
19.                 return;
    
20.             }
    
21.             closed = true;
    
22.         }
    
23.         if (channel != null) {
    
24.             /*
    
25.              * Decrement FD use count associated with the channel. The FD use
    
26.              * count is incremented whenever a new channel is obtained from
    
27.              * this stream.
    
28.              */
    
29.             fd.decrementAndGetUseCount();
    
30.             channel.close();
    
31.         }
    
32. 
    
33.         /*
    
34.          * Decrement FD use count associated with this stream.
    
35.          * The count got incremented by FileDescriptor during its construction.
    
36.          */
    
37.         fd.decrementAndGetUseCount();
    
38.         close0();
    
39.     }
    

復(fù)制代碼

ddd010

仔細想了下，問題不一定在close里面的同步哪兒。
我也沒有理解透，求指點。