El hilo de Java bloquea al registrar el canal con el selector mientras se llama a select(). ¿Qué hacer?

Question

Tengo una pregunta básica. Por qué y cómo el método de registro de SelectableChannel puede estar en la llamada de bloqueo. Déjame proporcionar un escenario.

He creado un objeto selector en la clase Regístrese de la siguiente manera.

private static Selector selector = Selector.open(); 

También tengo un método en la misma clase (Registrarse) para registrar el canal con el selector.

public static SelectionKey registerChannel(SelectableChannel channel, 
      int ops) throws IOException { 

     channel.configureBlocking(false); 
     return channel.register(selector, ops); 
    } 

Y hay otra clase llamada de solicitud, el cual tiene un método que lee los datos de los canales, los procesos y las llamadas siguientes método para registrar el canal.

selectonKey = Register.register(socketChannel, SelectionKey.OP_READ); 

Aquí en este punto el hilo está bloqueado, sin dar la pista de lo que está esperando. He verificado que el selector está abierto. Por favor, dame algo de ayuda para entender cómo puedo resolver esto. ¿Hay algún bloqueo que pueda liberar?

Cualquier entrada sería apreciada.

Agregando a lo que describí. Pruebas adicionales revelaron que si el método Register.register se llama desde el mismo hilo, puede registrarse, pero luego si otro hilo intenta invocar el método, thread doesn, t move ahead.

Answer 1

¿Ha intentado imprimir un seguimiento de la pila de todos los hilos en su programa (usando kill -QUIT en Unix o Ctrl + Break en Windows o usando la utilidad jstack)?

AbstractSelectableChannel contiene un bloqueo en el que configureBlocking y register deben sincronizarse. También se puede acceder a este bloqueo a través del método blockingLock(), por lo que otro subproceso podría contener el bloqueo, lo que provocaría que su llamada de registro se bloquee indefinidamente (pero sin un seguimiento de pila es difícil de detectar).

Answer 2

Debe usar un candado y sincronizar manualmente.

En el mismo hilo está ejecutando el bucle de selección tienen una ReentrantLock:

final ReentrantLock selectorLock = new ReentrantLock(); 

Luego, cuando es necesario registrarse con el selector de hacer algo como esto:

selectorLock.lock(); 
try { 
    selector.wakeup(); 
    socketChannel.register(selector, ops); 
} finally { 
    selectorLock.unlock(); 
} 

Por último, durante su loop que está llamando accept(), algo como esto:

selectorLock.lock(); 
selectorLock.unlock(); 

selector.select(500); 

yt Seguirá con el resto de su lógica.

Esta construcción garantiza que la llamada register() no bloqueará al asegurar que nunca otra select() es entre correspondiente wakeup()register() y llamadas.

Answer 3

Esta es una característica básica de la mayoría de las implementaciones de NIO que no es obvia en la documentación.

Usted necesita para hacer todas las llamadas del registro de la misma rosca que está haciendo su selección o callejones sin salida va a producir. Por lo general, esto se hace proporcionando una cola de registros/desregistros/cambios de interés en los que se escribe y luego se llama a selector.wakeup(). Cuando se despierta el hilo de selección, comprueba la cola y realiza las operaciones solicitadas.

Answer 4

Registra tu canal desde cualquier tema:

synchronized (selectorLock2) { 
    selector.wakeup(); 
    synchronized (selectorLock1) { 
     channel.register(selector, ops); 
    } 
} 

su bucle de selección debe tener este aspecto:

while (true) { 
    synchronized (selectorLock1) { 
     selector.select(); 
    } 
    synchronized (selectorLock2) {} 

    .... 
}