Skip to content

Commit 2860c5c

Browse files
committed
Fix the comment
1 parent 2b85e7e commit 2860c5c

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

projects/RabbitMQ.Client/client/impl/AsyncConsumerWorkService.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,7 @@ public void Schedule<TWork>(ModelBase model, TWork work) where TWork : Work
1616
/*
1717
* rabbitmq/rabbitmq-dotnet-client#841
1818
* https://docs.microsoft.com/en-us/dotnet/api/system.collections.concurrent.concurrentdictionary-2.getoradd
19-
* Note that the value delegate is not atomic but instances of this class are not meant to be used by
20-
* multiple threads.
19+
* Note that the value delegate is not atomic but the Schedule method will not be called concurrently.
2120
*/
2221
WorkPool workPool = _workPools.GetOrAdd(model, _startNewWorkPoolFunc);
2322
workPool.Enqueue(work);

projects/RabbitMQ.Client/client/impl/ConsumerWorkService.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,7 @@ public void AddWork(IModel model, Action fn)
1515
/*
1616
* rabbitmq/rabbitmq-dotnet-client#841
1717
* https://docs.microsoft.com/en-us/dotnet/api/system.collections.concurrent.concurrentdictionary-2.getoradd
18-
* Note that the value delegate is not atomic but instances of this class are not meant to be used by
19-
* multiple threads.
18+
* Note that the value delegate is not atomic but the AddWork method will not be called concurrently.
2019
*/
2120
WorkPool workPool = _workPools.GetOrAdd(model, _startNewWorkPoolFunc);
2221
workPool.Enqueue(fn);

0 commit comments

Comments
 (0)