Java timeOut的实现

     用NIO socket读取网络数据，找了好久没找到，NIO下设置读超时的API，只好自己写了一个。

     思路是设置守护进程，启动后等待 一定的时间，如果在等待一定的时间后还没被唤醒，则抛出超时异常。

 

        //设置超时守护进程
                         TimeOutThread t = new TimeOutThread(5000,new TimeoutException("reading      timeOut"));
                         t.start();
                        
                        
                         count=client.read(protocalNum);  
                         count=client.read(functionNum);
                         count=client.read(messageLen);
                         messageLen.rewind();
                         int length = messageLen.asIntBuffer().get(0);
                      
                         receivebuffer = ByteBuffer.allocate(length-12);
                         receivebuffer.clear();
                         
                         count=client.read(receivebuffer);
                                             
                       t.cancel();
                       notifyAll(); 

 

        TimeOutThread.java

 

    private long timeOut ;
    private boolean isCanceled = false;
    private TimeoutException exception;
   
    public TimeOutThread(long timeOut,TimeoutException exception){
     super();
     this.timeOut = timeOut;
     this.exception = exception;
     this.setDaemon(true);
    }
   
    public synchronized void cancel(){
     this.isCanceled = true;
     
    }
   
    public synchronized void  run(){
     try{
      wait(timeOut);
      if(!isCanceled){
       throw exception;
      }
     }
     catch(InterruptedException e){
      e.printStackTrace();
     }
    }

 

    TimeOutException.java 就不写了。

 

  

评论

2 楼 九尾狐的yi巴 2017-02-27  

Jenercy 写道

目测没用。TimeOutThread抛出的TimeoutException 最终会被拦截并且打印出来。
而且TimeOutThread抛出异常只会让TimeOutThread这个线程结束运行，对主线程不会产生影响。超时后只会打印出超时信息，主线程的代码仍然会继续运行，调用该函数的代码仍然会卡住。不信可以在主线程里写个死循环看能不能在超时后结束

确实是这样 有没有什么解决办法？

1 楼 Jenercy 2017-01-03  

目测没用。TimeOutThread抛出的TimeoutException 最终会被拦截并且打印出来。
而且TimeOutThread抛出异常只会让TimeOutThread这个线程结束运行，对主线程不会产生影响。超时后只会打印出超时信息，主线程的代码仍然会继续运行，调用该函数的代码仍然会卡住。不信可以在主线程里写个死循环看能不能在超时后结束