MailBoxComponent.cs 710 B

1234567891011121314151617181920212223242526272829303132333435363738
  1. using System.Collections.Generic;
  2. namespace ETModel
  3. {
  4. public struct ActorMessageInfo
  5. {
  6. public Session Session;
  7. public object Message;
  8. }
  9. /// <summary>
  10. /// 挂上这个组件表示该Entity是一个Actor,接收的消息将会队列处理
  11. /// </summary>
  12. public class MailBoxComponent: Component
  13. {
  14. // Mailbox的类型
  15. public string MailboxType;
  16. // 队列处理消息
  17. public Queue<ActorMessageInfo> Queue = new Queue<ActorMessageInfo>();
  18. public ETTaskCompletionSource<ActorMessageInfo> Tcs;
  19. public override void Dispose()
  20. {
  21. if (this.IsDisposed)
  22. {
  23. return;
  24. }
  25. base.Dispose();
  26. var t = this.Tcs;
  27. this.Tcs = null;
  28. t?.SetResult(new ActorMessageInfo());
  29. }
  30. }
  31. }