comparison Implab/Parallels/ThreadPoolDispatcher.cs @ 248:5cb4826c2c2a v3

Added awaiters to promises Added static methods to Promise Resolve, Reject, All. Updated promise helpers
author cin
date Tue, 30 Jan 2018 01:37:17 +0300
parents
children
comparison
equal deleted inserted replaced
247:fb70574741a1 248:5cb4826c2c2a
1 using System;
2 using System.Threading;
3
4 namespace Implab.Parallels {
5 public class ThreadPoolDispatcher : IDispatcher {
6
7 public static ThreadPoolDispatcher Instance { get; private set; } = new ThreadPoolDispatcher();
8
9 private ThreadPoolDispatcher() {
10 }
11
12 public void Enqueue(Action job) {
13 ThreadPool.QueueUserWorkItem((o) => job(), null);
14 }
15
16 public void Enqueue<T>(Action<T> job, T arg) {
17 ThreadPool.QueueUserWorkItem((o) => job((T)o), arg);
18 }
19 }
20 }