using System.Collections.Generic; using System.Net; using System.Threading; using System.Threading.Tasks; namespace ETModel { public sealed class ActorMessageSender : ComponentWithId { // actor的地址 public IPEndPoint Address; public long ActorId; // 还没发送的消息 public Queue WaitingTasks = new Queue(); // 最近发送消息的时间 public long LastSendTime; public TaskCompletionSource tcs; public int FailTimes; public int MaxFailTimes; } }