爪哇：拋出異常給另一個線程

Question

我有一個Java這樣的代碼：在運行（）方法

private class Uploader implements Runnable 
{ 
    // ... 

public void start() 
{ 
    t.start(); 
} 

public void run() 
{ 
     try { 

     while(i=in.read()) 
     { 
      output.write(i); // THIS IS A BLOCKING CALL !! 
     } 

     } catch(ProtocolException e) { ... } 
      catch(IOException e1) { ... } 
} 

private void restore() 
{ 
     ... 
} 

private class Checker implements Runnable 
{ 
      // ... 

    @Override 
    public void run() 
    { 
       // I WANT (IN A PARTICULAR MOMENT) TO THROW AN 
       // EXCEPTION INTO THE Uploader RUN METHOD FROM HERE, 
       // IS IT POSSIBLE? 
    } 
} 
} 

的問題是，我有一個阻擋寫（），所以我已經添加了一個 檢查連接是否正在傳輸的新線程：如果它不是傳輸，我想使用異常機制（從檢查器線程拋出異常到另一個線程的run（）方法）阻止阻塞write（）。 這可能嗎？

EDIT [解決]：

的唯一方法是，以粗暴關閉輸出流，並就寫入的位的量的工作來檢查連接是否正在發送：

private class Uploader implements Runnable 
{ 
    private OutputStream output; 

    private int readedBits; 

    public void run() 
    { 
     try { 

      while(i=in.read()) 
      { 
       output.write(i); 

       readedBits++; 
      } 

     } catch(IOException e1) 
       { 
        // ENTERS HERE IF RESTORE() IS CALLED 
       } 
    } 

    private void restore() 
    { 
     try { 
      output.close(); 
     } catch (IOException e) {} 

     // Restore connection .... 
    } 

    private int getReadedBits() 
    { 
     return this.readedBits; 
    } 

    private class Checker implements Runnable 
    { 
      // ... 

     @Override 
     public void run() 
     { 
      while(true) 
      { 
       try { 
        Thread.sleep(timeout); 
       } catch (InterruptedException e1) {} 

       if(lastReaded >= getReadedBits()) 
        restore(); 
       else 
        lastReaded = getReadedBits(); 
      } 
     } 
    } 
} 

Answer 1

通常，在I/O上阻塞時，唯一的辦法就是關閉資源。正如@VolkerK所說，另一種方法是使用非阻塞I/O，這比較困難。

Answer 2

您可以讓您的代碼兌現Thread.interrupt()致電。看到這個調用的javadoc。

Answer 3

我推薦使用這個中斷。 Checker可能會在Uploader類中調用中斷。

例如

private class Checker implements Runnable 
{ 
     // ... 
    Uploader uploader; 
    public Checker(Uploader uploader) { 
     this.uploader = uploader; 
    } 
    @Override 
    public void run() 
    { 
      // CHECK 
      if(failed) uploader.interrupt(); 
    } 
} 

文檔是在這裏：http://docs.oracle.com/javase/tutorial/essential/concurrency/interrupt.html

Answer 4

不是你問什麼的，但我寧願使用java.nio和
public abstract int select(long timeout) throws IOException
到（不僅）檢測超時。