1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
SolutionCrawler\WorkCoordinator.NormalPriorityProcessor.cs (1)
55_workItemQueue = new AsyncDocumentWorkItemQueue(processor._registration.ProgressReporter, processor._registration.Workspace);
11 references to _workItemQueue
Microsoft.CodeAnalysis.Features (11)
SolutionCrawler\WorkCoordinator.NormalPriorityProcessor.cs (11)
69var added = _workItemQueue.AddOrReplace(item); 98=> _workItemQueue.WaitAsync(cancellationToken); 101public int WorkItemCount => _workItemQueue.WorkItemCount; 102public bool HasAnyWork => _workItemQueue.HasAnyWork; 129if (!_workItemQueue.TryTakeAnyWork( 178_workItemQueue.RequestCancellationOnRunningTasks(); 230if (!_workItemQueue.TryTake(documentId, out var workItem, out var documentCancellation)) 337_workItemQueue.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem"))); 343_workItemQueue.MarkWorkItemDoneFor(workItem.DocumentId); 535_workItemQueue.Dispose(); 563while (_normalPriorityProcessor._workItemQueue.HasAnyWork)