如何從正在工作線程上讀取的文件讀取主線程上的數據

Question

我正在處理一個巨大的數據文件，並將其作爲「在下面張貼」，並在單獨的線程中讀取它。而在主線程中，我想檢索一些數據frm文件，如logFile.getFileHash.getTimeStamp，以在該timeStamp上執行一些操作。我面臨的問題是，只有當我的文件在其他線程中完全讀取時，如何開始從主線程的文件中讀取一些數據？

注意：我不想對讀取文件的同一線程上的文件檢索到的數據執行操作，我想在主線程上執行此操作。

例如

public static void main(String[] args) throws IOException { 

//fileThread.start(); will take 8 seconds. 
/* 
*here i want to read some data from my file to perform some processing but only 
*when the thread that handles reading the file finishes work. 
} 

文件

private static void processFile(File dataFile) throws IOException { 
    // TODO Auto-generated method stub 
    MeasurementFile logfile = new MeasurementFile(dataFile); 
    System.out.println(logfile.getTotalLines()); 
    System.out.println(logfile.getFileHash().get(logfile.getTotalLines()).getFullParameters().length); 
    System.out.println(logfile.getFileHash().get(logfile.getTotalLines()).getEngineSpeed()); 
} 

Answer 1

嘗試使用CountDownLatch等到讀者完成：http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/CountDownLatch.html

Answer 2

Thread.join能適應這一點。

public static void main(String[] args) throws IOException { 

fileThread.start(); 
fileThread.join(); 
//..now this thread blocks until *fileThread* exits 

} 

Answer 3

在文件線程中添加一個屬性併爲其添加一個公共getter。當該線程完成時，將isFinished的值更改爲true;

private boolean finished = false; 
public isFinished(){...} 

在你的主線程，只是睡了吧，恢復它來檢查文件線程完成：

public static void main(String[] args) throws IOException { 
    ... 
    fileThread.start(); 
    ... 
    while(!fileThread.isFinished()){ 
     try{ 
      Thread.sleep(1000);//1 second or whatever you want 
     }catch(Exception e){} 
    } 
    //Do something 
    .... 
} 

Answer 4

我不知道我理解的問題，但我認爲你正在嘗試在子線程完成讀取而不結束子線程之後，讓主線程讀取同一文件。如果是這樣，那麼你可以創建一個同步的readMyFile（File file）方法，任何線程都可以使用它來讀取任何文件，當然要確保子線程首先讀取文件。

Answer 5

對不起，延遲迴復。

如果我認爲是正確的，那麼你可以做這樣的事情，大致...

public static void main(String args[]) { 

    ... 
    fileThread.start(); 

    synchronized (fileThread) { 
     try{ 
      fileThread.wait(); 
     }catch(InterruptedException e){ 
      e.printStackTrace(); 
     } 
    } 
    ... 
    MyReader.readMyFile(file); 
    ... 
} 

...而fileThread線程類的東西作爲...

class FileThread extends Thread { 

public void run() { 

    synchronized (this){ 
     ... 
     MyReader.readMyFile(file); 
     notify(); 
     ... 
    } 
} 

這是一種方式。我希望它有幫助。