1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingNormalPriorityProcessor.cs (1)
53_workItemQueue = new UnitTestingAsyncDocumentWorkItemQueue(processor._registration.ProgressReporter);
10 references to _workItemQueue
Microsoft.CodeAnalysis.Features (10)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingNormalPriorityProcessor.cs (10)
67var added = _workItemQueue.AddOrReplace(item); 96=> _workItemQueue.WaitAsync(cancellationToken); 100public int WorkItemCount => _workItemQueue.WorkItemCount; 101public bool HasAnyWork => _workItemQueue.HasAnyWork; 122if (!_workItemQueue.TryTakeAnyWork( 162_workItemQueue.RequestCancellationOnRunningTasks(); 239_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 245_workItemQueue.MarkWorkItemDoneFor(workItem.DocumentId); 359_workItemQueue.Dispose(); 387while (_normalPriorityProcessor._workItemQueue.HasAnyWork)