Changeset 13937 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs

Timestamp:

06/24/16 21:23:47 (8 years ago)

Author:

thasling

Message:

#2615:
implemented ConcurrentQueue
made minor changes in Dispose-methods

File:

• branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs (modified) (3 diffs)

branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs

@@ -7 +7 @@
 using DistributedGA.Core.Domain;
 using DistributedGA.Core.Interface;
+using DistributedGA.Core.Util;
 
 namespace DistributedGA.Core.Implementation {
@@ -13 +14 @@
     private PeerInfo myself;
 
-    private ConcurrentQueue<KeyValuePair<PeerInfo, byte[][]>> bufferedMessages;
+    private SizedConcurrentQueue<KeyValuePair<PeerInfo, byte[][]>> bufferedMessages;
 
     private Timer timer; //sends cached messages to network in background
@@ -19 +20 @@
     public void Init(PeerInfo source) {
       myself = source;
-      bufferedMessages = new ConcurrentQueue<KeyValuePair<PeerInfo, byte[][]>>();
+      bufferedMessages = new SizedConcurrentQueue<KeyValuePair<PeerInfo, byte[][]>>();
+      bufferedMessages.Limit = 1000;
       timer = new Timer(1000 * 60); //each 5 minutes
       timer.Elapsed += GenerateSendingTasks;