1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingLowPriorityProcessor.cs (1)
36_workItemQueue = new UnitTestingAsyncProjectWorkItemQueue(processor._registration.ProgressReporter);
10 references to _workItemQueue
Microsoft.CodeAnalysis.Features (10)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingLowPriorityProcessor.cs (10)
41public int WorkItemCount => _workItemQueue.WorkItemCount; 44=> _workItemQueue.WaitAsync(cancellationToken); 53if (_workItemQueue.TryTakeAnyWork( 86_workItemQueue.RequestCancellationOnRunningTasks(); 96var added = _workItemQueue.AddOrReplace(item); 114_workItemQueue.RequestCancellationOnRunningTasks(); 164_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 170_workItemQueue.MarkWorkItemDoneFor(projectId); 177_workItemQueue.Dispose(); 209while (_lowPriorityProcessor._workItemQueue.HasAnyWork)