这篇文章给大家分享两个类JAMailboxFactory和Request。
JAMailboxFactory
JAMailboxFactory类用来管理线程池(thread pool)和创建(邮箱)mailboxes,它有一个很方便的带int参数的构造函数可以规定线程池的容量。
关闭线程池可以用close()方法。
创建可以被征用的邮箱(Mailbox)可以使用createMailbox()。(线程安全的邮箱,你可以认为这是创建同步邮箱)
createAsyncMailbox(),用来创建异步邮箱。
Request
所有Actor之间的请求必须继承自一个泛型类Request,这个泛型类有两个参数:一个是RESPONSE_TYPE,当请求被成功处理后所返回的结果类;一个是TARGET_TYPE 结果,用来判断请求者是否是目标类的实例。
isTargetType(targetActor)方法是抽象方法,当targetActor是TargetType的实例时应返回true。(其子类必须实现此方法。)
抽象方法processRequest(targetActor,rp)通常回调actor的一些方法。对于actor的异步方法,rp参数仅仅是被简单的传到actor的方法里;而对于actor的同步方法,参数rp的 processResult(result)方法必须连同actor方法的结果一同被回调。(即便是actor的返回结果是空的也必须返回)
(有一点需要注意,processRequest()方法应该在适当的线程中调用,那样可以维持线程安全,通常是actor在使用同一个线程在发消息,但不一定)。
send(sourceActor,targetActor,rp)方法用来从一个actor向另一个actor发送一个两向请求消息,rp用来回调处理结果。(rp的processResponse方法通常在sourceActor线 程安全的情况下被调用。)
send(jaFuture,targetActor)方法用来从无actor的代码里发送双向消息,此方法在返回结果之前将一起等待,结果返回了它将立即返回。
sendEvent(sourceActor,targetActor)方法用来从一个actor向另一个actor发送单向消息。
sendEvent(targetActor)方法用来从代码向一个actor发送消息。