terraria-cpp2il v1.4.4.9
Terraria mobile dump, with CallAnalysis (see source code). Dump with reconstucted method: https://infinitynichto.github.io/terraria-cpp2il-methodrecon
Loading...
Searching...
No Matches
ThreadPoolWorkQueue.cs
Go to the documentation of this file.
1using System;
2using System.Runtime.ConstrainedExecution;
3using Cpp2ILInjected;
4using Cpp2ILInjected.CallAnalysis;
5
6namespace System.Threading
7{
8 [global::Cpp2ILInjected.Token(Token = "0x2000200")]
9 internal sealed class ThreadPoolWorkQueue
10 {
11 [global::Cpp2ILInjected.Token(Token = "0x6001239")]
12 [global::Cpp2ILInjected.Address(RVA = "0x1C9E568", Offset = "0x1C9E568", Length = "0x6C")]
13 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolGlobals), Member = ".cctor", ReturnType = typeof(void))]
14 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
15 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(object), Member = ".ctor", ReturnType = typeof(void))]
16 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.QueueSegment), Member = ".ctor", ReturnType = typeof(void))]
17 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 4)]
18 public ThreadPoolWorkQueue()
19 {
20 throw null;
21 }
22
23 [global::Cpp2ILInjected.Token(Token = "0x600123A")]
24 [global::Cpp2ILInjected.Address(RVA = "0x1C9E630", Offset = "0x1C9E630", Length = "0x84")]
25 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dispatch", ReturnType = typeof(bool))]
26 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
27 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = ".ctor", MemberParameters = new object[] { typeof(ThreadPoolWorkQueue) }, ReturnType = typeof(void))]
28 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 6)]
33
34 [global::Cpp2ILInjected.Token(Token = "0x600123B")]
35 [global::Cpp2ILInjected.Address(RVA = "0x1C9E7C4", Offset = "0x1C9E7C4", Length = "0x98")]
36 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
37 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Enqueue", MemberParameters = new object[]
38 {
39 typeof(IThreadPoolWorkItem),
40 typeof(bool)
41 }, ReturnType = typeof(void))]
42 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dispatch", ReturnType = typeof(bool))]
43 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 6)]
44 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 6)]
45 internal void EnsureThreadRequested()
46 {
47 throw null;
48 }
49
50 [global::Cpp2ILInjected.Token(Token = "0x600123C")]
51 [global::Cpp2ILInjected.Address(RVA = "0x1C9E864", Offset = "0x1C9E864", Length = "0x48")]
52 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
53 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dispatch", ReturnType = typeof(bool))]
54 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
55 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 3)]
56 internal void MarkThreadRequestSatisfied()
57 {
58 throw null;
59 }
60
61 [global::Cpp2ILInjected.Token(Token = "0x600123D")]
62 [global::Cpp2ILInjected.Address(RVA = "0x1C9E8AC", Offset = "0x1C9E8AC", Length = "0x128")]
63 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = "CleanUp", ReturnType = typeof(void))]
64 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPool), Member = "QueueUserWorkItemHelper", MemberParameters = new object[]
65 {
66 typeof(WaitCallback),
67 typeof(object),
68 typeof(ref StackCrawlMark),
69 typeof(bool),
70 typeof(bool)
71 }, ReturnType = typeof(bool))]
72 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPool), Member = "UnsafeQueueCustomWorkItem", MemberParameters = new object[]
73 {
74 typeof(IThreadPoolWorkItem),
75 typeof(bool)
76 }, ReturnType = typeof(void))]
77 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 3)]
78 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "LocalPush", MemberParameters = new object[] { typeof(IThreadPoolWorkItem) }, ReturnType = typeof(void))]
79 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.QueueSegment), Member = "TryEnqueue", MemberParameters = new object[] { typeof(IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
80 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.QueueSegment), Member = ".ctor", ReturnType = typeof(void))]
81 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue), Member = "EnsureThreadRequested", ReturnType = typeof(void))]
82 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 13)]
83 public void Enqueue(IThreadPoolWorkItem callback, bool forceGlobal)
84 {
85 throw null;
86 }
87
88 [global::Cpp2ILInjected.Token(Token = "0x600123E")]
89 [global::Cpp2ILInjected.Address(RVA = "0x1C9EE38", Offset = "0x1C9EE38", Length = "0x68")]
90 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPool), Member = "TryPopCustomWorkItem", MemberParameters = new object[] { typeof(IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
91 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
92 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 2)]
93 internal bool LocalFindAndPop(IThreadPoolWorkItem callback)
94 {
95 throw null;
96 }
97
98 [global::Cpp2ILInjected.Token(Token = "0x600123F")]
99 [global::Cpp2ILInjected.Address(RVA = "0x1C9F0FC", Offset = "0x1C9F0FC", Length = "0x1A4")]
100 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
101 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dispatch", ReturnType = typeof(bool))]
102 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
103 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "LocalPop", MemberParameters = new object[] { typeof(ref IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
104 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.QueueSegment), Member = "TryDequeue", MemberParameters = new object[] { typeof(ref IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
105 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.SparseArray<>), Member = "get_Current", ReturnType = "T[]")]
106 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "TrySteal", MemberParameters = new object[]
107 {
108 typeof(ref IThreadPoolWorkItem),
109 typeof(ref bool),
110 typeof(int)
111 }, ReturnType = typeof(bool))]
112 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 10)]
113 public void Dequeue(ThreadPoolWorkQueueThreadLocals tl, out IThreadPoolWorkItem callback, out bool missedSteal)
114 {
115 throw null;
116 }
117
118 [global::Cpp2ILInjected.Token(Token = "0x6001240")]
119 [global::Cpp2ILInjected.Address(RVA = "0x1C9F5B8", Offset = "0x1C9F5B8", Length = "0x440")]
120 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
121 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(_ThreadPoolWaitCallback), Member = "PerformWaitCallback", ReturnType = typeof(bool))]
122 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
123 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(global::System.Environment), Member = "get_TickCount", ReturnType = typeof(int))]
124 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue), Member = "MarkThreadRequestSatisfied", ReturnType = typeof(void))]
125 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue), Member = "EnsureCurrentThreadHasQueue", ReturnType = typeof(ThreadPoolWorkQueueThreadLocals))]
126 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue), Member = "Dequeue", MemberParameters = new object[]
127 {
128 typeof(ThreadPoolWorkQueueThreadLocals),
129 typeof(ref IThreadPoolWorkItem),
130 typeof(ref bool)
131 }, ReturnType = typeof(void))]
132 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue), Member = "EnsureThreadRequested", ReturnType = typeof(void))]
133 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 29)]
134 internal static bool Dispatch()
135 {
136 throw null;
137 }
138
139 // Note: this type is marked as 'beforefieldinit'.
140 [global::Cpp2ILInjected.Token(Token = "0x6001241")]
141 [global::Cpp2ILInjected.Address(RVA = "0x1C9F9FC", Offset = "0x1C9F9FC", Length = "0x90")]
142 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
143 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.SparseArray<>), Member = ".ctor", MemberParameters = new object[] { typeof(int) }, ReturnType = typeof(void))]
144 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 4)]
145 static ThreadPoolWorkQueue()
146 {
147 throw null;
148 }
149
150 [global::Cpp2ILInjected.Token(Token = "0x40009B8")]
151 [global::Cpp2ILInjected.FieldOffset(Offset = "0x10")]
152 internal ThreadPoolWorkQueue.QueueSegment queueHead;
153
154 [global::Cpp2ILInjected.Token(Token = "0x40009B9")]
155 [global::Cpp2ILInjected.FieldOffset(Offset = "0x18")]
156 internal ThreadPoolWorkQueue.QueueSegment queueTail;
157
158 [global::Cpp2ILInjected.Token(Token = "0x40009BA")]
159 internal static ThreadPoolWorkQueue.SparseArray<ThreadPoolWorkQueue.WorkStealingQueue> allThreadQueues;
160
161 [global::Cpp2ILInjected.Token(Token = "0x40009BB")]
162 [global::Cpp2ILInjected.FieldOffset(Offset = "0x20")]
163 private int numOutstandingThreadRequests;
164
165 [global::Cpp2ILInjected.Token(Token = "0x2000201")]
166 internal class SparseArray<T> where T : class
167 {
168 [global::Cpp2ILInjected.Token(Token = "0x6001242")]
169 [global::Cpp2ILInjected.Address(RVA = "0x186E944", Offset = "0x186E944", Length = "0x54")]
170 [global::Cpp2ILInjected.CallAnalysis.DeduplicatedMethod]
171 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = ".cctor", ReturnType = typeof(void))]
172 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
173 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(object), Member = ".ctor", ReturnType = typeof(void))]
174 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 3)]
175 internal SparseArray(int initialSize)
176 {
177 throw null;
178 }
179
180 [global::Cpp2ILInjected.Token(Token = "0x170001BF")]
181 internal T[] Current
182 {
183 [global::Cpp2ILInjected.Token(Token = "0x6001243")]
184 [global::Cpp2ILInjected.Address(RVA = "0x186E998", Offset = "0x186E998", Length = "0x18")]
185 [global::Cpp2ILInjected.CallAnalysis.DeduplicatedMethod]
186 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dequeue", MemberParameters = new object[]
187 {
188 typeof(ThreadPoolWorkQueueThreadLocals),
189 typeof(ref IThreadPoolWorkItem),
190 typeof(ref bool)
191 }, ReturnType = typeof(void))]
192 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
193 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 1)]
194 get
195 {
196 throw null;
197 }
198 }
199
200 [global::Cpp2ILInjected.Token(Token = "0x6001244")]
201 [global::Cpp2ILInjected.Address(RVA = "0x186E9B0", Offset = "0x186E9B0", Length = "0x1BC")]
202 [global::Cpp2ILInjected.CallAnalysis.DeduplicatedMethod]
203 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
204 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = ".ctor", MemberParameters = new object[] { typeof(ThreadPoolWorkQueue) }, ReturnType = typeof(void))]
205 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
206 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(Monitor), Member = "Enter", MemberParameters = new object[]
207 {
208 typeof(object),
209 typeof(ref bool)
210 }, ReturnType = typeof(void))]
211 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(global::System.Array), Member = "Copy", MemberParameters = new object[]
212 {
213 typeof(global::System.Array),
214 typeof(global::System.Array),
215 typeof(int)
216 }, ReturnType = typeof(void))]
217 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(Monitor), Member = "Exit", MemberParameters = new object[] { typeof(object) }, ReturnType = typeof(void))]
218 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 12)]
219 internal int Add(T e)
220 {
221 throw null;
222 }
223
224 [global::Cpp2ILInjected.Token(Token = "0x6001245")]
225 [global::Cpp2ILInjected.Address(RVA = "0x186EB6C", Offset = "0x186EB6C", Length = "0x124")]
226 [global::Cpp2ILInjected.CallAnalysis.DeduplicatedMethod]
227 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
228 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = "CleanUp", ReturnType = typeof(void))]
229 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
230 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(Monitor), Member = "Enter", MemberParameters = new object[]
231 {
232 typeof(object),
233 typeof(ref bool)
234 }, ReturnType = typeof(void))]
235 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(Monitor), Member = "Exit", MemberParameters = new object[] { typeof(object) }, ReturnType = typeof(void))]
236 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 11)]
237 internal void Remove(T e)
238 {
239 throw null;
240 }
241
242 [global::Cpp2ILInjected.Token(Token = "0x40009BC")]
243 [global::Cpp2ILInjected.FieldOffset(Offset = "0x0")]
244 private T[] m_array;
245 }
246
247 [global::Cpp2ILInjected.Token(Token = "0x2000202")]
248 internal class WorkStealingQueue
249 {
250 [global::Cpp2ILInjected.Token(Token = "0x6001246")]
251 [global::Cpp2ILInjected.Address(RVA = "0x1C9E9D4", Offset = "0x1C9E9D4", Length = "0x3D4")]
252 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
253 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Enqueue", MemberParameters = new object[]
254 {
255 typeof(IThreadPoolWorkItem),
256 typeof(bool)
257 }, ReturnType = typeof(void))]
258 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
259 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Enter", MemberParameters = new object[] { typeof(ref bool) }, ReturnType = typeof(void))]
260 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Exit", MemberParameters = new object[] { typeof(bool) }, ReturnType = typeof(void))]
261 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 46)]
262 public void LocalPush(IThreadPoolWorkItem obj)
263 {
264 throw null;
265 }
266
267 [global::Cpp2ILInjected.Token(Token = "0x6001247")]
268 [global::Cpp2ILInjected.Address(RVA = "0x1C9EEA0", Offset = "0x1C9EEA0", Length = "0x25C")]
269 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
270 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
271 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Enter", MemberParameters = new object[] { typeof(ref bool) }, ReturnType = typeof(void))]
272 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Exit", MemberParameters = new object[] { typeof(bool) }, ReturnType = typeof(void))]
273 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "LocalPop", MemberParameters = new object[] { typeof(ref IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
274 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 25)]
275 public bool LocalFindAndPop(IThreadPoolWorkItem obj)
276 {
277 throw null;
278 }
279
280 [global::Cpp2ILInjected.Token(Token = "0x6001248")]
281 [global::Cpp2ILInjected.Address(RVA = "0x1C9F2A0", Offset = "0x1C9F2A0", Length = "0x208")]
282 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
283 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "LocalFindAndPop", MemberParameters = new object[] { typeof(IThreadPoolWorkItem) }, ReturnType = typeof(bool))]
284 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dequeue", MemberParameters = new object[]
285 {
286 typeof(ThreadPoolWorkQueueThreadLocals),
287 typeof(ref IThreadPoolWorkItem),
288 typeof(ref bool)
289 }, ReturnType = typeof(void))]
290 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = "CleanUp", ReturnType = typeof(void))]
291 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 3)]
292 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Enter", MemberParameters = new object[] { typeof(ref bool) }, ReturnType = typeof(void))]
293 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Exit", MemberParameters = new object[] { typeof(bool) }, ReturnType = typeof(void))]
294 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 21)]
295 public bool LocalPop(out IThreadPoolWorkItem obj)
296 {
297 throw null;
298 }
299
300 [global::Cpp2ILInjected.Token(Token = "0x6001249")]
301 [global::Cpp2ILInjected.Address(RVA = "0x1C9F5B0", Offset = "0x1C9F5B0", Length = "0x8")]
302 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
303 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "TrySteal", MemberParameters = new object[]
304 {
305 typeof(ref IThreadPoolWorkItem),
306 typeof(ref bool),
307 typeof(int)
308 }, ReturnType = typeof(bool))]
309 public bool TrySteal(out IThreadPoolWorkItem obj, ref bool missedSteal)
310 {
311 throw null;
312 }
313
314 [global::Cpp2ILInjected.Token(Token = "0x600124A")]
315 [global::Cpp2ILInjected.Address(RVA = "0x1C9FA90", Offset = "0x1C9FA90", Length = "0x204")]
316 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
317 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue.WorkStealingQueue), Member = "TrySteal", MemberParameters = new object[]
318 {
319 typeof(ref IThreadPoolWorkItem),
320 typeof(ref bool)
321 }, ReturnType = typeof(bool))]
322 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dequeue", MemberParameters = new object[]
323 {
324 typeof(ThreadPoolWorkQueueThreadLocals),
325 typeof(ref IThreadPoolWorkItem),
326 typeof(ref bool)
327 }, ReturnType = typeof(void))]
328 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 2)]
329 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "TryEnter", MemberParameters = new object[]
330 {
331 typeof(int),
332 typeof(ref bool)
333 }, ReturnType = typeof(void))]
334 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = "Exit", MemberParameters = new object[] { typeof(bool) }, ReturnType = typeof(void))]
335 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 17)]
336 private bool TrySteal(out IThreadPoolWorkItem obj, ref bool missedSteal, int millisecondsTimeout)
337 {
338 throw null;
339 }
340
341 [global::Cpp2ILInjected.Token(Token = "0x600124B")]
342 [global::Cpp2ILInjected.Address(RVA = "0x1C9FC94", Offset = "0x1C9FC94", Length = "0x94")]
343 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueueThreadLocals), Member = ".ctor", MemberParameters = new object[] { typeof(ThreadPoolWorkQueue) }, ReturnType = typeof(void))]
344 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
345 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinLock), Member = ".ctor", MemberParameters = new object[] { typeof(bool) }, ReturnType = typeof(void))]
346 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(object), Member = ".ctor", ReturnType = typeof(void))]
347 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 4)]
348 public WorkStealingQueue()
349 {
350 throw null;
351 }
352
353 [global::Cpp2ILInjected.Token(Token = "0x40009BD")]
354 [global::Cpp2ILInjected.FieldOffset(Offset = "0x10")]
355 internal IThreadPoolWorkItem[] m_array;
356
357 [global::Cpp2ILInjected.Token(Token = "0x40009BE")]
358 [global::Cpp2ILInjected.FieldOffset(Offset = "0x18")]
359 private int m_mask;
360
361 [global::Cpp2ILInjected.Token(Token = "0x40009BF")]
362 [global::Cpp2ILInjected.FieldOffset(Offset = "0x1C")]
363 private int m_headIndex;
364
365 [global::Cpp2ILInjected.Token(Token = "0x40009C0")]
366 [global::Cpp2ILInjected.FieldOffset(Offset = "0x20")]
367 private int m_tailIndex;
368
369 [global::Cpp2ILInjected.Token(Token = "0x40009C1")]
370 [global::Cpp2ILInjected.FieldOffset(Offset = "0x24")]
371 private SpinLock m_foreignLock;
372 }
373
374 [global::Cpp2ILInjected.Token(Token = "0x2000203")]
375 internal class QueueSegment
376 {
377 [global::Cpp2ILInjected.Token(Token = "0x600124C")]
378 [global::Cpp2ILInjected.Address(RVA = "0x1C9FD28", Offset = "0x1C9FD28", Length = "0x34")]
379 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
380 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 1)]
381 private void GetIndexes(out int upper, out int lower)
382 {
383 throw null;
384 }
385
386 [global::Cpp2ILInjected.Token(Token = "0x600124D")]
387 [global::Cpp2ILInjected.Address(RVA = "0x1C9FD5C", Offset = "0x1C9FD5C", Length = "0x68")]
388 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
389 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
390 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 2)]
391 private bool CompareExchangeIndexes(ref int prevUpper, int newUpper, ref int prevLower, int newLower)
392 {
393 throw null;
394 }
395
396 [global::System.Runtime.ConstrainedExecution.ReliabilityContract(global::System.Runtime.ConstrainedExecution.Consistency.WillNotCorruptState, global::System.Runtime.ConstrainedExecution.Cer.MayFail)]
397 [global::Cpp2ILInjected.Token(Token = "0x600124E")]
398 [global::Cpp2ILInjected.Address(RVA = "0x1C9E5D4", Offset = "0x1C9E5D4", Length = "0x5C")]
399 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = ".ctor", ReturnType = typeof(void))]
400 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Enqueue", MemberParameters = new object[]
401 {
402 typeof(IThreadPoolWorkItem),
403 typeof(bool)
404 }, ReturnType = typeof(void))]
405 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 2)]
406 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(object), Member = ".ctor", ReturnType = typeof(void))]
407 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 2)]
408 public QueueSegment()
409 {
410 throw null;
411 }
412
413 [global::Cpp2ILInjected.Token(Token = "0x600124F")]
414 [global::Cpp2ILInjected.Address(RVA = "0x1C9F574", Offset = "0x1C9F574", Length = "0x3C")]
415 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
416 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 0)]
417 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 1)]
418 public bool IsUsedUp()
419 {
420 throw null;
421 }
422
423 [global::Cpp2ILInjected.Token(Token = "0x6001250")]
424 [global::Cpp2ILInjected.Address(RVA = "0x1C9EDA8", Offset = "0x1C9EDA8", Length = "0x8C")]
425 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
426 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Enqueue", MemberParameters = new object[]
427 {
428 typeof(IThreadPoolWorkItem),
429 typeof(bool)
430 }, ReturnType = typeof(void))]
431 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 2)]
432 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 4)]
433 public bool TryEnqueue(IThreadPoolWorkItem node)
434 {
435 throw null;
436 }
437
438 [global::Cpp2ILInjected.Token(Token = "0x6001251")]
439 [global::Cpp2ILInjected.Address(RVA = "0x1C9F4A8", Offset = "0x1C9F4A8", Length = "0xCC")]
440 [global::Cpp2ILInjected.CallAnalysis.ContainsUnimplementedInstructions]
441 [global::Cpp2ILInjected.CallAnalysis.CalledBy(Type = typeof(ThreadPoolWorkQueue), Member = "Dequeue", MemberParameters = new object[]
442 {
443 typeof(ThreadPoolWorkQueueThreadLocals),
444 typeof(ref IThreadPoolWorkItem),
445 typeof(ref bool)
446 }, ReturnType = typeof(void))]
447 [global::Cpp2ILInjected.CallAnalysis.CallerCount(Count = 1)]
448 [global::Cpp2ILInjected.CallAnalysis.Calls(Type = typeof(SpinWait), Member = "SpinOnce", ReturnType = typeof(void))]
449 [global::Cpp2ILInjected.CallAnalysis.CallsUnknownMethods(Count = 4)]
450 public bool TryDequeue(out IThreadPoolWorkItem node)
451 {
452 throw null;
453 }
454
455 [global::Cpp2ILInjected.Token(Token = "0x40009C2")]
456 [global::Cpp2ILInjected.FieldOffset(Offset = "0x10")]
457 internal readonly IThreadPoolWorkItem[] nodes;
458
459 [global::Cpp2ILInjected.Token(Token = "0x40009C3")]
460 [global::Cpp2ILInjected.FieldOffset(Offset = "0x18")]
461 private int indexes;
462
463 [global::Cpp2ILInjected.Token(Token = "0x40009C4")]
464 [global::Cpp2ILInjected.FieldOffset(Offset = "0x20")]
465 public ThreadPoolWorkQueue.QueueSegment Next;
466 }
467 }
468}
j__TPar
class f__AnonymousType0<< Count > j__TPar
Definition --f__AnonymousType0.cs:11
System.Threading.ThreadPoolWorkQueue.QueueSegment.CompareExchangeIndexes
bool CompareExchangeIndexes(ref int prevUpper, int newUpper, ref int prevLower, int newLower)
Definition ThreadPoolWorkQueue.cs:391
System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.TrySteal
bool TrySteal(out IThreadPoolWorkItem obj, ref bool missedSteal)
Definition ThreadPoolWorkQueue.cs:309
System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.TrySteal
bool TrySteal(out IThreadPoolWorkItem obj, ref bool missedSteal, int millisecondsTimeout)
Definition ThreadPoolWorkQueue.cs:336
System.Threading.ThreadPoolWorkQueue.Enqueue
void Enqueue(IThreadPoolWorkItem callback, bool forceGlobal)
Definition ThreadPoolWorkQueue.cs:83
System.Threading.ThreadPoolWorkQueue.LocalFindAndPop
bool LocalFindAndPop(IThreadPoolWorkItem callback)
Definition ThreadPoolWorkQueue.cs:93
System.Threading.ThreadPoolWorkQueue.Dequeue
void Dequeue(ThreadPoolWorkQueueThreadLocals tl, out IThreadPoolWorkItem callback, out bool missedSteal)
Definition ThreadPoolWorkQueue.cs:113
System.Threading.ThreadPoolWorkQueue.EnsureCurrentThreadHasQueue
ThreadPoolWorkQueueThreadLocals EnsureCurrentThreadHasQueue()
Definition ThreadPoolWorkQueue.cs:29
System.Threading.ThreadPoolWorkQueue.queueHead
ThreadPoolWorkQueue.QueueSegment queueHead
Definition ThreadPoolWorkQueue.cs:152
System.Threading.ThreadPoolWorkQueue.allThreadQueues
static ThreadPoolWorkQueue.SparseArray< ThreadPoolWorkQueue.WorkStealingQueue > allThreadQueues
Definition ThreadPoolWorkQueue.cs:159
System.Threading.ThreadPoolWorkQueue.queueTail
ThreadPoolWorkQueue.QueueSegment queueTail
Definition ThreadPoolWorkQueue.cs:156
System.Threading._ThreadPoolWaitCallback
Definition _ThreadPoolWaitCallback.cs:9