ThreadedRunner.cs 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. using System;
  2. using System.Threading;
  3. #if NET_STANDARD_2_0
  4. using System.Threading.Tasks;
  5. #endif
  6. namespace BestHTTP.PlatformSupport.Threading
  7. {
  8. public static class ThreadedRunner
  9. {
  10. public static void RunShortLiving<T>(Action<T> job, T param)
  11. {
  12. #if NETFX_CORE
  13. #pragma warning disable 4014
  14. Windows.System.Threading.ThreadPool.RunAsync(_ => job(param));
  15. #pragma warning restore 4014
  16. #elif NET_STANDARD_2_0
  17. var _task = new Task(() => job(param));
  18. _task.ConfigureAwait(false);
  19. _task.Start();
  20. #else
  21. ThreadPool.QueueUserWorkItem(new WaitCallback(_ => job(param)));
  22. #endif
  23. }
  24. public static void RunShortLiving<T1, T2>(Action<T1, T2> job, T1 param1, T2 param2)
  25. {
  26. #if NETFX_CORE
  27. #pragma warning disable 4014
  28. Windows.System.Threading.ThreadPool.RunAsync((param) => job(param1, param2));
  29. #pragma warning restore 4014
  30. #elif NET_STANDARD_2_0
  31. var _task = new Task(() => job(param1, param2));
  32. _task.ConfigureAwait(false);
  33. _task.Start();
  34. #else
  35. ThreadPool.QueueUserWorkItem(new WaitCallback(_ => job(param1, param2)));
  36. #endif
  37. }
  38. public static void RunShortLiving<T1, T2, T3>(Action<T1, T2, T3> job, T1 param1, T2 param2, T3 param3)
  39. {
  40. #if NETFX_CORE
  41. #pragma warning disable 4014
  42. Windows.System.Threading.ThreadPool.RunAsync((param) => job(param1, param2, param3));
  43. #pragma warning restore 4014
  44. #elif NET_STANDARD_2_0
  45. var _task = new Task(() => job(param1, param2, param3));
  46. _task.ConfigureAwait(false);
  47. _task.Start();
  48. #else
  49. ThreadPool.QueueUserWorkItem(new WaitCallback(_ => job(param1, param2, param3)));
  50. #endif
  51. }
  52. public static void RunShortLiving<T1, T2, T3, T4>(Action<T1, T2, T3, T4> job, T1 param1, T2 param2, T3 param3, T4 param4)
  53. {
  54. #if NETFX_CORE
  55. #pragma warning disable 4014
  56. Windows.System.Threading.ThreadPool.RunAsync((param) => job(param1, param2, param3, param4));
  57. #pragma warning restore 4014
  58. #elif NET_STANDARD_2_0
  59. var _task = new Task(() => job(param1, param2, param3, param4));
  60. _task.ConfigureAwait(false);
  61. _task.Start();
  62. #else
  63. ThreadPool.QueueUserWorkItem(new WaitCallback(_ => job(param1, param2, param3, param4)));
  64. #endif
  65. }
  66. public static void RunShortLiving(Action job)
  67. {
  68. #if NETFX_CORE
  69. #pragma warning disable 4014
  70. Windows.System.Threading.ThreadPool.RunAsync((param) => job());
  71. #pragma warning restore 4014
  72. #elif NET_STANDARD_2_0
  73. var _task = new Task(() => job());
  74. _task.ConfigureAwait(false);
  75. _task.Start();
  76. #else
  77. ThreadPool.QueueUserWorkItem(new WaitCallback((param) => job()));
  78. #endif
  79. }
  80. public static void RunLongLiving(Action job)
  81. {
  82. #if NETFX_CORE
  83. #pragma warning disable 4014
  84. Windows.System.Threading.ThreadPool.RunAsync((param) => job());
  85. #pragma warning restore 4014
  86. #elif NET_STANDARD_2_0
  87. var _task = new Task(() => job(), TaskCreationOptions.LongRunning);
  88. _task.ConfigureAwait(false);
  89. _task.Start();
  90. #else
  91. var thread = new Thread(new ParameterizedThreadStart((param) => job()));
  92. thread.IsBackground = true;
  93. thread.Start();
  94. #endif
  95. }
  96. }
  97. }