diff --git a/src/libraries/System.Threading.Tasks.Parallel/tests/ParallelForEachAsyncTests.cs b/src/libraries/System.Threading.Tasks.Parallel/tests/ParallelForEachAsyncTests.cs index 304f144bad05463855ebf4b975a5329b9388e3e4..661df3abdbd989df4cc2cc648a0f20f2fd422d46 100644 --- a/src/libraries/System.Threading.Tasks.Parallel/tests/ParallelForEachAsyncTests.cs +++ b/src/libraries/System.Threading.Tasks.Parallel/tests/ParallelForEachAsyncTests.cs @@ -124,7 +124,6 @@ static IEnumerable IterateUntilSet(StrongBox box) [InlineData(2)] [InlineData(4)] [InlineData(128)] - [ActiveIssue("https://github.com/dotnet/runtime/issues/50566", TestPlatforms.Android)] public async Task Dop_WorkersCreatedRespectingLimitAndTaskScheduler_Sync(int dop) { static IEnumerable IterateUntilSet(StrongBox box) @@ -141,7 +140,7 @@ static IEnumerable IterateUntilSet(StrongBox box) int activeWorkers = 0; var block = new TaskCompletionSource(); - const int MaxSchedulerLimit = 2; + int MaxSchedulerLimit = Math.Min(2, Environment.ProcessorCount); Task t = Parallel.ForEachAsync(IterateUntilSet(box), new ParallelOptions { MaxDegreeOfParallelism = dop, TaskScheduler = new MaxConcurrencyLevelPassthroughTaskScheduler(MaxSchedulerLimit) }, async (item, cancellationToken) => {