5 implementations of IThreadPoolWorkItem
mscorlib (5)
system\threading\SemaphoreSlim.cs (1)
87
private sealed class TaskNode : Task<bool>,
IThreadPoolWorkItem
system\threading\Tasks\Task.cs (2)
146
public class Task :
IThreadPoolWorkItem
, IAsyncResult, IDisposable
6680
internal sealed class CompletionActionInvoker :
IThreadPoolWorkItem
system\threading\Tasks\TaskContinuation.cs (1)
543
internal class AwaitTaskContinuation : TaskContinuation,
IThreadPoolWorkItem
system\threading\threadpool.cs (1)
1182
internal sealed class QueueUserWorkItemCallback :
IThreadPoolWorkItem
42 references to IThreadPoolWorkItem
mscorlib (42)
system\threading\SemaphoreSlim.cs (2)
93
void
IThreadPoolWorkItem
.ExecuteWorkItem()
100
void
IThreadPoolWorkItem
.MarkAborted(ThreadAbortException tae) { /* nop */ }
system\threading\Tasks\Task.cs (2)
2701
void
IThreadPoolWorkItem
.ExecuteWorkItem()
2711
void
IThreadPoolWorkItem
.MarkAborted(ThreadAbortException tae)
system\threading\Tasks\TaskContinuation.cs (2)
703
void
IThreadPoolWorkItem
.ExecuteWorkItem()
721
void
IThreadPoolWorkItem
.MarkAborted(ThreadAbortException tae) { /* nop */ }
system\threading\Tasks\ThreadPoolTaskScheduler.cs (2)
116
private IEnumerable<Task> FilterTasksFromWorkItems(IEnumerable<
IThreadPoolWorkItem
> tpwItems)
118
foreach (
IThreadPoolWorkItem
tpwi in tpwItems)
system\threading\threadpool.cs (34)
139
internal volatile
IThreadPoolWorkItem
[] m_array = new
IThreadPoolWorkItem
[INITIAL_SIZE];
154
public void LocalPush(
IThreadPoolWorkItem
obj)
211
IThreadPoolWorkItem
[] newArray = new
IThreadPoolWorkItem
[m_array.Length << 1];
234
public bool LocalFindAndPop(
IThreadPoolWorkItem
obj)
239
IThreadPoolWorkItem
unused;
296
public bool LocalPop(out
IThreadPoolWorkItem
obj)
360
public bool TrySteal(out
IThreadPoolWorkItem
obj, ref bool missedSteal)
365
private bool TrySteal(out
IThreadPoolWorkItem
obj, ref bool missedSteal, int millisecondsTimeout)
422
internal readonly
IThreadPoolWorkItem
[] nodes;
472
nodes = new
IThreadPoolWorkItem
[QueueSegmentLength];
484
public bool TryEnqueue(
IThreadPoolWorkItem
node)
514
public bool TryDequeue(out
IThreadPoolWorkItem
node)
615
public void Enqueue(
IThreadPoolWorkItem
callback, bool forceGlobal)
648
internal bool LocalFindAndPop(
IThreadPoolWorkItem
callback)
658
public void Dequeue(ThreadPoolWorkQueueThreadLocals tl, out
IThreadPoolWorkItem
callback, out bool missedSteal)
739
IThreadPoolWorkItem
workItem = null;
899
IThreadPoolWorkItem
cb = null;
1235
void
IThreadPoolWorkItem
.ExecuteWorkItem()
1255
void
IThreadPoolWorkItem
.MarkAborted(ThreadAbortException tae)
1654
internal static void UnsafeQueueCustomWorkItem(
IThreadPoolWorkItem
workItem, bool forceGlobal)
1671
internal static bool TryPopCustomWorkItem(
IThreadPoolWorkItem
workItem)
1681
internal static IEnumerable<
IThreadPoolWorkItem
> GetQueuedWorkItems()
1686
internal static IEnumerable<
IThreadPoolWorkItem
> EnumerateQueuedWorkItems(ThreadPoolWorkQueue.WorkStealingQueue[] wsQueues, ThreadPoolWorkQueue.QueueSegment globalQueueTail)
1695
IThreadPoolWorkItem
[] items = wsq.m_array;
1698
IThreadPoolWorkItem
item = items[i];
1713
IThreadPoolWorkItem
[] items = segment.nodes;
1716
IThreadPoolWorkItem
item = items[i];
1725
internal static IEnumerable<
IThreadPoolWorkItem
> GetLocallyQueuedWorkItems()
1731
internal static IEnumerable<
IThreadPoolWorkItem
> GetGloballyQueuedWorkItems()
1736
private static object[] ToObjectArray(IEnumerable<
IThreadPoolWorkItem
> workitems)
1739
foreach (
IThreadPoolWorkItem
item in workitems)
1746
foreach (
IThreadPoolWorkItem
item in workitems)