|
|
@@ -2,8 +2,8 @@
|
|
|
|
|
|
namespace ET
|
|
|
{
|
|
|
- [ComponentOf(typeof(VProcess))]
|
|
|
- public class VProcessActor: SingletonEntity<VProcessActor>, IAwake
|
|
|
+ [ComponentOf(typeof(Fiber))]
|
|
|
+ public class FiberActor: SingletonEntity<FiberActor>, IAwake
|
|
|
{
|
|
|
private readonly Dictionary<int, ETTask<IResponse>> requestCallbacks = new();
|
|
|
|
|
|
@@ -20,19 +20,19 @@ namespace ET
|
|
|
|
|
|
base.Dispose();
|
|
|
|
|
|
- ActorQueue.Instance.RemoveQueue((int)this.Root().Id);
|
|
|
+ ActorMessageQueue.Instance.RemoveQueue((int)this.Root().Id);
|
|
|
}
|
|
|
|
|
|
public void Awake()
|
|
|
{
|
|
|
- ActorQueue.Instance.AddQueue((int)this.Root().Id);
|
|
|
+ ActorMessageQueue.Instance.AddQueue((int)this.Root().Id);
|
|
|
}
|
|
|
|
|
|
public void Update()
|
|
|
{
|
|
|
this.list.Clear();
|
|
|
- VProcess vProcess = this.Root();
|
|
|
- ActorQueue.Instance.Fetch((int)vProcess.Id, 1000, this.list);
|
|
|
+ Fiber fiber = this.Root();
|
|
|
+ ActorMessageQueue.Instance.Fetch((int)fiber.Id, 1000, this.list);
|
|
|
|
|
|
ActorMessageDispatcherComponent actorMessageDispatcherComponent = ActorMessageDispatcherComponent.Instance;
|
|
|
foreach (ActorMessageInfo actorMessageInfo in this.list)
|
|
|
@@ -43,7 +43,7 @@ namespace ET
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
- Entity entity = vProcess.ActorEntities.Get(actorMessageInfo.ActorId);
|
|
|
+ Entity entity = fiber.ActorEntities.Get(actorMessageInfo.ActorId);
|
|
|
actorMessageDispatcherComponent.Handle(entity, actorMessageInfo.ActorId, actorMessageInfo.MessageObject).Coroutine();
|
|
|
}
|
|
|
}
|
|
|
@@ -55,8 +55,8 @@ namespace ET
|
|
|
|
|
|
public void Send(ActorId actorId, MessageObject messageObject)
|
|
|
{
|
|
|
- VProcess vProcess = this.Root();
|
|
|
- ActorQueue.Instance.Send(new Address(vProcess.Process, (int)vProcess.Id), actorId, messageObject);
|
|
|
+ Fiber fiber = this.Root();
|
|
|
+ ActorMessageQueue.Instance.Send(new Address(fiber.Process, (int)fiber.Id), actorId, messageObject);
|
|
|
}
|
|
|
}
|
|
|
}
|