java - 并行处理 Set

Question

我有一组客户端，以及一个我想向他们广播的事件。更准确地说，我使用 CopyOnWriteArraySet 来避免 ConcurrentModificationException。

一切运行良好，但我开始遇到大量客户端的性能问题。

您能建议一种并行服务客户的方法吗？

广播循环现在看起来基本上是这样的:

for (Client client : clients) {
    sendTo(client, event);
}

Answer 1

使用 Java 8，您可以将循环替换为:

clients.parallelForEach(client -> sendTo(client, event));

使用 Java 7，您将需要手动编写代码。第一个简单版本如下所示:

private final ExecutorService executor = new FixedThreadPool(N_THREADS);

private void send(Set<Client> clients, final Event event) {
    for (Client client : clients) {
        final Client c = client;
        executor.submit(new Runnable() { public void run() { sendTo(c, event); }});
    }
}