Fixed incorrect return of the source to the pool

sakno · sakno · commit 0b35f049a6e4 · 2025-10-22T20:24:59.000+03:00
diff --git a/src/DotNext.Threading/Threading/CancellationTokenMultiplexer.cs b/src/DotNext.Threading/Threading/CancellationTokenMultiplexer.cs
@@ -110,7 +110,7 @@ private void ReturnCore(PooledCancellationTokenSource source)
             source.Next = current;
             tmp = Interlocked.CompareExchange(ref firstInPool, source, current);
 
-            if (ReferenceEquals(tmp, source))
+            if (ReferenceEquals(tmp, current))
                 break;
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -110,7 +110,7 @@ private void ReturnCore(PooledCancellationTokenSource source)`
`110`	`110`	`source.Next = current;`
`111`	`111`	`tmp = Interlocked.CompareExchange(ref firstInPool, source, current);`
`112`	`112`
`113`		`- if (ReferenceEquals(tmp, source))`
	`113`	`+ if (ReferenceEquals(tmp, current))`
`114`	`114`	`break;`
`115`	`115`	`}`
`116`	`116`	`}`