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