1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
SolutionCrawler\WorkCoordinator.HighPriorityProcessor.cs (1)
46
_workItemQueue
= new AsyncDocumentWorkItemQueue(processor._registration.ProgressReporter, processor._registration.Workspace);
9 references to _workItemQueue
Microsoft.CodeAnalysis.Features (9)
SolutionCrawler\WorkCoordinator.HighPriorityProcessor.cs (9)
68
public int WorkItemCount =>
_workItemQueue
.WorkItemCount;
69
public bool HasAnyWork =>
_workItemQueue
.HasAnyWork;
119
var added =
_workItemQueue
.AddOrReplace(item);
126
=>
_workItemQueue
.WaitAsync(cancellationToken);
168
if (
_workItemQueue
.TryTake(documentId, out workItem, out cancellationToken))
174
return
_workItemQueue
.TryTakeAnyWork(
222
_workItemQueue
.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem")));
228
_workItemQueue
.MarkWorkItemDoneFor(workItem.DocumentId);
233
=>
_workItemQueue
.Dispose();