| 12345678910111213141516171819202122232425 |
- 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<ActorTask> WaitingTasks = new Queue<ActorTask>();
-
- // 最近发送消息的时间
- public long LastSendTime;
- public TaskCompletionSource<ActorTask> tcs;
- public CancellationTokenSource CancellationTokenSource;
- public int failTimes;
- }
- }
|