PollingManager.cs 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Collections.Concurrent;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using UnityEngine;
  8. /// <summary>
  9. /// 轮询管理器
  10. /// </summary>
  11. public class PollingManager : MonoSingleton<PollingManager>
  12. {
  13. /// <summary>
  14. /// 轮询事务
  15. /// </summary>
  16. public class PollItem
  17. {
  18. /// <summary>
  19. /// 唯一id
  20. /// </summary>
  21. public string Id;
  22. /// <summary>
  23. /// 回调函数
  24. /// </summary>
  25. public Action Callback;
  26. /// <summary>
  27. /// 时间间隔(秒)
  28. /// </summary>
  29. public int Interval_sec;
  30. public void Update()
  31. {
  32. timespan += Time.deltaTime;
  33. if (timespan > Interval_sec)
  34. {
  35. timespan -= Interval_sec;
  36. Callback?.Invoke();
  37. }
  38. }
  39. /// <summary>
  40. /// 时间
  41. /// </summary>
  42. private float timespan = 0;
  43. }
  44. Dictionary<string, PollItem> PollItems = new Dictionary<string, PollItem>();
  45. /// <summary>
  46. /// 注册轮询事务
  47. /// </summary>
  48. /// <param name="Uni_ID">字符串:唯一id</param>
  49. /// <param name="interval_seconds">时间间隔,单位:秒(若需更高精度请自行管理你的轮询)</param>
  50. /// <param name="callBack">回调函数</param>
  51. public void Register(string Uni_ID, int interval_seconds, Action callBack)
  52. {
  53. PollItems[Uni_ID] = new PollItem { Id = Uni_ID, Interval_sec = interval_seconds, Callback = callBack };
  54. }
  55. /// <summary>
  56. /// 删除轮询事务
  57. /// </summary>
  58. /// <param name="Uni_ID"></param>
  59. public void Unregister(string Uni_ID)
  60. {
  61. if (PollItems.ContainsKey(Uni_ID))
  62. {
  63. PollItems.Remove(Uni_ID);
  64. }
  65. }
  66. private void FixedUpdate()
  67. {
  68. foreach (var item in PollItems.Values) { item.Update(); }
  69. }
  70. }