1 write to _workItemQueue
Microsoft.CodeAnalysis.Features (1)
SolutionCrawler\WorkCoordinator.LowPriorityProcessor.cs (1)
37
_workItemQueue
= new AsyncProjectWorkItemQueue(processor._registration.ProgressReporter, processor._registration.Workspace);
10 references to _workItemQueue
Microsoft.CodeAnalysis.Features (10)
SolutionCrawler\WorkCoordinator.LowPriorityProcessor.cs (10)
42
public int WorkItemCount =>
_workItemQueue
.WorkItemCount;
45
=>
_workItemQueue
.WaitAsync(cancellationToken);
59
if (
_workItemQueue
.TryTakeAnyWork(
92
_workItemQueue
.RequestCancellationOnRunningTasks();
102
var added =
_workItemQueue
.AddOrReplace(item);
120
_workItemQueue
.RequestCancellationOnRunningTasks();
173
_workItemQueue
.AddOrReplace(workItem.Retry(Listener.BeginAsyncOperation("ReenqueueWorkItem")));
179
_workItemQueue
.MarkWorkItemDoneFor(projectId);
194
_workItemQueue
.Dispose();
226
while (_lowPriorityProcessor.
_workItemQueue
.HasAnyWork)