From 4dde62e65be51cb1db7a39daaba295f73b682b12 Mon Sep 17 00:00:00 2001 From: Roger Johansson Date: Fri, 27 May 2022 18:19:56 +0200 Subject: [PATCH] Change default mailbox queue (#1622) --- src/Proto.Actor/Mailbox/Mailbox.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Proto.Actor/Mailbox/Mailbox.cs b/src/Proto.Actor/Mailbox/Mailbox.cs index 5dcb2d732f..c7fe48b383 100644 --- 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