1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingNormalPriorityProcessor.cs (1)
56_workItemQueue = new UnitTestingAsyncDocumentWorkItemQueue(processor._registration.ProgressReporter);
11 references to _workItemQueue
Microsoft.CodeAnalysis.Features (11)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingNormalPriorityProcessor.cs (11)
70var added = _workItemQueue.AddOrReplace(item); 99=> _workItemQueue.WaitAsync(cancellationToken); 102public int WorkItemCount => _workItemQueue.WorkItemCount; 103public bool HasAnyWork => _workItemQueue.HasAnyWork; 130if (!_workItemQueue.TryTakeAnyWork( 192_workItemQueue.RequestCancellationOnRunningTasks(); 244if (!_workItemQueue.TryTake(documentId, out var workItem, out var documentCancellation)) 353_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 359_workItemQueue.MarkWorkItemDoneFor(workItem.DocumentId); 583_workItemQueue.Dispose(); 611while (_normalPriorityProcessor._workItemQueue.HasAnyWork)