[AMQNET-649] bugs in PooledTaskRunner.cs

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.7.2
• Component/s: ActiveMQ
• Assignee: Unassigned
• Reporter: JEFF ANDERSON
• Created: 30/Nov/20 19:18
• Updated: 30/Nov/20 19:51

Description

Although the 1.7.2 release of the AMQ .net client uses the DedicatedTaskRunner runner by default. We compile from source and use PooledTaskRunner.cs for performance reasons. However this code has some bugs. Namely the Shutdown() method will deadlock on a call to Thread.Sleep with infinite timespan. If you look at the Java source for PooledTaskRunner, it looks like the C# port is missing the thread synchronization logic that the Java implementation has. I've attached a version which corrects this and makes it in-line with the Java implementation and corrects the logic in Shutdown which needs to be a synchronized wait (e.g., Monitor.Wait())