爪哇：抛出异常给另一个线程

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
到（不仅）检测超时。