1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingLowPriorityProcessor.cs (1)
37_workItemQueue = new UnitTestingAsyncProjectWorkItemQueue(processor._registration.ProgressReporter);
10 references to _workItemQueue
Microsoft.CodeAnalysis.Features (10)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingLowPriorityProcessor.cs (10)
42public int WorkItemCount => _workItemQueue.WorkItemCount; 45=> _workItemQueue.WaitAsync(cancellationToken); 54if (_workItemQueue.TryTakeAnyWork( 87_workItemQueue.RequestCancellationOnRunningTasks(); 97var added = _workItemQueue.AddOrReplace(item); 115_workItemQueue.RequestCancellationOnRunningTasks(); 165_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 171_workItemQueue.MarkWorkItemDoneFor(projectId); 178_workItemQueue.Dispose(); 210while (_lowPriorityProcessor._workItemQueue.HasAnyWork)