ActorMessageSenderComponent.cs 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. using System;
  2. using System.Collections.Generic;
  3. namespace ETModel
  4. {
  5. public class ActorMessageSenderComponent: Component
  6. {
  7. public readonly Dictionary<long, ActorMessageSender> ActorMessageSenders = new Dictionary<long, ActorMessageSender>();
  8. public override void Dispose()
  9. {
  10. if (this.IsDisposed)
  11. {
  12. return;
  13. }
  14. base.Dispose();
  15. foreach (ActorMessageSender actorMessageSender in this.ActorMessageSenders.Values)
  16. {
  17. actorMessageSender.Dispose();
  18. }
  19. this.ActorMessageSenders.Clear();
  20. }
  21. public ActorMessageSender Get(long actorId)
  22. {
  23. if (actorId == 0)
  24. {
  25. throw new Exception($"actor id is 0");
  26. }
  27. if (this.ActorMessageSenders.TryGetValue(actorId, out ActorMessageSender actorMessageSender))
  28. {
  29. return actorMessageSender;
  30. }
  31. actorMessageSender = ComponentFactory.CreateWithId<ActorMessageSender, long>(actorId, actorId);
  32. actorMessageSender.Parent = this;
  33. this.ActorMessageSenders[actorId] = actorMessageSender;
  34. return actorMessageSender;
  35. }
  36. public void Remove(long id)
  37. {
  38. if (!this.ActorMessageSenders.TryGetValue(id, out ActorMessageSender actorMessageSender))
  39. {
  40. return;
  41. }
  42. this.ActorMessageSenders.Remove(id);
  43. actorMessageSender.Dispose();
  44. }
  45. }
  46. }