Change default mailbox queue (#1622)

asynkron · May 27, 2022 · 4dde62e · 4dde62e
1 parent 74bf3c5
commit 4dde62e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Proto.Actor/Mailbox/Mailbox.cs b/src/Proto.Actor/Mailbox/Mailbox.cs
@@ -32,13 +32,13 @@ public interface IMailbox
 public static class BoundedMailbox
 {
     public static IMailbox Create(int size, params IMailboxStatistics[] stats) =>
-        new DefaultMailbox(new UnboundedMailboxQueue(), new BoundedMailboxQueue(size), stats);
+        new DefaultMailbox(new LockingUnboundedMailboxQueue(4), new BoundedMailboxQueue(size), stats);
 }
 
 public static class UnboundedMailbox
 {
     public static IMailbox Create(params IMailboxStatistics[] stats) =>
-        new DefaultMailbox(new UnboundedMailboxQueue(), new UnboundedMailboxQueue(), stats);
+        new DefaultMailbox(new LockingUnboundedMailboxQueue(4), new UnboundedMailboxQueue(), stats);
 }
 
 public sealed class DefaultMailbox : IMailbox