java - Java - 在数据接收时向另一个线程触发事件

Question

我必须编写一个管理多个数据报套接字的服务器。我知道 java.nio 的选择器功能，它允许对不同的套接字进行异步管理但是，在解析完消息后，我需要将事件触发到另一个线程（可选地使用一些参数）。有没有办法让其他线程“注册”到管理套接字的线程并让他们知道数据已经为他们准备好了？提前致谢

Answer 1

您可以使用支持异步网络调用的 ExecutorService。此时返回的 Future 可以在完成时充当消息传递者。

public class SocketWork<T>{

    private final ExecutorService service = Executors.newSingleThreadExecutor();
    private final Future<T> future;

    public SocketWork(){
        future = service.submit(new SocketWorkCallable<T>());    
    }

    public T register(){
        // all threads entering register will block until 
        // the SocketWorkCallable is completed and returns.
       return future.get();
    }
}

另一种方法是使用 CountdownLatch。

public class SocketWork<T>{

    private final CountdownLatch latch = new CountdownLatch(1);
    private T message;

    public void executeSocketWork(){
        //execute work and get message
        this.message = returnedMessage;
        latch.countDown();
    }

    public T register(){
        latch.await();
        return message;
    }
}

你也可以用 ReadWriteLock 做类似的事情。

您可以想象，这仅适用于单个任务。每个实例SocketWork