Paralellize broadcast

planetarium · Jun 18, 2021 · 1a8b758 · 1a8b758
1 parent eaabdcf
commit 1a8b758
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -216,6 +216,7 @@ To be released.
  -  `ActionEvaluator<T>.EvaluateActions()` now throws an unmanaged exception
     if `OutOfMemoryException` is caught from `IAction.Execute()`.
     [[#1320], [#1343]]
+ -  Improved performance of broadcasting using `Swarm<T>`.  [[#1334]]
 
 ### Bug fixes
 
@@ -299,6 +300,7 @@ To be released.
 [#1320]: https://github.com/planetarium/libplanet/issues/1320
 [#1325]: https://github.com/planetarium/libplanet/pull/1325
 [#1328]: https://github.com/planetarium/libplanet/pull/1328
+[#1334]: https://github.com/planetarium/libplanet/pull/1334
 [#1339]: https://github.com/planetarium/libplanet/issues/1339
 [#1342]: https://github.com/planetarium/libplanet/pull/1342
 [#1343]: https://github.com/planetarium/libplanet/pull/1343

diff --git a/Libplanet/Net/Transports/NetMQTransport.cs b/Libplanet/Net/Transports/NetMQTransport.cs
@@ -620,7 +620,7 @@ private void DoBroadcast(object sender, NetMQQueueEventArgs<(Address?, Message)>
                     DateTimeOffset.UtcNow,
                     _appProtocolVersion);
 
-                foreach (BoundPeer peer in peers)
+                peers.AsParallel().ForAll(peer =>
                 {
                     string endpoint = peer.ToNetMQAddress();
                     if (!_dealers.TryGetValue(peer.Address, out DealerSocket dealer) ||
@@ -647,7 +647,7 @@ private void DoBroadcast(object sender, NetMQQueueEventArgs<(Address?, Message)>
                         dealer.Dispose();
                         _dealers.TryRemove(peer.Address, out _);
                     }
-                }
+                });
             }
             catch (Exception exc)
             {