DBTaskQueue.cs 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Threading.Tasks;
  4. namespace ETModel
  5. {
  6. [ObjectSystem]
  7. public class DbTaskQueueAwakeSystem : AwakeSystem<DBTaskQueue>
  8. {
  9. public override void Awake(DBTaskQueue self)
  10. {
  11. self.queue.Clear();
  12. }
  13. }
  14. [ObjectSystem]
  15. public class DbTaskQueueStartSystem : StartSystem<DBTaskQueue>
  16. {
  17. public override async void Start(DBTaskQueue self)
  18. {
  19. long instanceId = self.InstanceId;
  20. while (true)
  21. {
  22. if (self.InstanceId != instanceId)
  23. {
  24. return;
  25. }
  26. DBTask task = await self.Get();
  27. try
  28. {
  29. await task.Run();
  30. }
  31. catch (Exception e)
  32. {
  33. Log.Error(e);
  34. }
  35. task.Dispose();
  36. }
  37. }
  38. }
  39. public sealed class DBTaskQueue : Component
  40. {
  41. public Queue<DBTask> queue = new Queue<DBTask>();
  42. public ETTaskCompletionSource<DBTask> tcs;
  43. public void Add(DBTask task)
  44. {
  45. if (this.tcs != null)
  46. {
  47. var t = this.tcs;
  48. this.tcs = null;
  49. t.SetResult(task);
  50. return;
  51. }
  52. this.queue.Enqueue(task);
  53. }
  54. public ETTask<DBTask> Get()
  55. {
  56. if (this.queue.Count > 0)
  57. {
  58. DBTask task = this.queue.Dequeue();
  59. return ETTask.FromResult(task);
  60. }
  61. ETTaskCompletionSource<DBTask> t = new ETTaskCompletionSource<DBTask>();
  62. this.tcs = t;
  63. return t.Task;
  64. }
  65. }
  66. }