如何在不使用選擇器的情況下實現阻止DatagramChannel的超時處理

Question

我覺得我錯過了這裏真正明顯的東西。

我的系統的整體結構讓我想要使用阻塞DatagramChannel而不使用選擇器，以保持簡單。 我想通過在套接字上設置超時來實現超時處理，但這似乎沒有效果。

這個僞代碼給出了我想要實現的一些提示。另一方面，我有一個UDP服務器，它提供五個快速響應，然後，爲了測試目的，在傳遞第六個響應之前延遲大約五秒鐘。

延遲不會觸發SocketTimeoutException。這是爲什麼？調用channel.receive時，套接字上設置的超時值似乎沒有考慮到。

問候， 弗雷德裏克

Answer 1

顯然不能夠超時的問題是不是與DatagramChannel的錯誤，但：

不是一個錯誤。 SocketChannel（和DatagramChannel）中的讀取方法不支持超時。如果您需要超時功能，請使用關聯的Socket（或DatagramSocket）對象的讀取方法 。

Link.

Answer 2

這是我做過什麼：

創建Interrupter類

static private class Interrupter implements Runnable 
{ 
    private final Thread th1; 
    private volatile int wait=-1; 
    private Interrupter(Thread ith1) 
    { 
     th1=ith1; 
    } 
    public void run() 
    { 
     while(true) 
     { 
      try{ 
       if(wait<0){ th1.join(); break; } 
       else{ Thread.sleep(wait); th1.interrupt(); wait=-1; } 
      } catch(Exception e){} 
     } 
    } 
} 

設置的Interrupter

Interrupter ir1=new Interrupter(Thread.currentThread()); 
Thread th1=new Thread(ir1); 
th1.start(); 
// We need this so that later the wait variable 
// can be passed in successfully 
while(th1.getState()!=Thread.State.WAITING); 

使用Interrupter

try{ 
    ir1.wait=waitTimeout; 
    th1.interrupt(); 
    // Receive on the socket 
    dc2.receive(bb2); 
} catch(ClosedByInterruptException e){ 
    // (Timed out) 
    Thread.interrupted(); 
    dc2.close(); 
    // Handle timeout here 
    // ... 
    // We need this so that later the wait variable 
    // can be passed in successfully 
    while(th1.getState()!=Thread.State.WAITING); 
} 
// Received packet 
ir1.wait=-1; 
th1.interrupt(); 
// We need this so that later the wait variable 
// can be passed in successfully 
while(th1.getState()!=Thread.State.WAITING); 
Thread.interrupted();