DBTaskQueue.cs 1.2 KB

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