This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 2234f70f54fd9182ac73f763283fd84053ed8b1a Author: Aaron Ai <[email protected]> AuthorDate: Fri Mar 17 13:49:54 2023 +0800 Add more stats info --- csharp/examples/ProducerBenchmark.cs | 2 +- csharp/rocketmq-client-csharp/Client.cs | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/csharp/examples/ProducerBenchmark.cs b/csharp/examples/ProducerBenchmark.cs index 5e3d4632..2b2ff427 100644 --- a/csharp/examples/ProducerBenchmark.cs +++ b/csharp/examples/ProducerBenchmark.cs @@ -30,7 +30,7 @@ namespace examples private static readonly Logger Logger = MqLogManager.Instance.GetCurrentClassLogger(); private static readonly SemaphoreSlim Semaphore = new SemaphoreSlim(0); - private const int TpsLimit = 300; + private const int TpsLimit = 1024; private static long _successCounter; private static long _failureCounter; diff --git a/csharp/rocketmq-client-csharp/Client.cs b/csharp/rocketmq-client-csharp/Client.cs index d619280b..2a2c9716 100644 --- a/csharp/rocketmq-client-csharp/Client.cs +++ b/csharp/rocketmq-client-csharp/Client.cs @@ -255,7 +255,9 @@ namespace Org.Apache.Rocketmq ThreadPool.GetAvailableThreads(out var availableWorker, out var availableIo); Logger.Info( $"ClientId={ClientId}, ClientVersion={MetadataConstants.Instance.ClientVersion}, " + - $".NET Version={Environment.Version}, AvailableWorkerThreads={availableWorker}, " + + $".NET Version={Environment.Version}, ThreadCount={ThreadPool.ThreadCount}, " + + $"CompletedWorkItemCount={ThreadPool.CompletedWorkItemCount}, " + + $"PendingWorkItemCount={ThreadPool.PendingWorkItemCount}, AvailableWorkerThreads={availableWorker}, " + $"AvailableCompletionPortThreads={availableIo}"); }
