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); 59if (_workItemQueue.TryTakeAnyWork( 104_workItemQueue.RequestCancellationOnRunningTasks(); 114var added = _workItemQueue.AddOrReplace(item); 132_workItemQueue.RequestCancellationOnRunningTasks(); 194_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 200_workItemQueue.MarkWorkItemDoneFor(projectId); 217_workItemQueue.Dispose(); 249while (_lowPriorityProcessor._workItemQueue.HasAnyWork)