yangweikuailewujian 2018-12-03 14:54
浏览 892

akka 邮箱测试,起多个jvm结果都不一样,求大侠指导


import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.UntypedActor;
import akka.dispatch.PriorityGenerator;
import akka.dispatch.UnboundedPriorityMailbox;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;


import java.io.File;

class MsgPriorityMailBox extends UnboundedPriorityMailbox {
    public  MsgPriorityMailBox(ActorSystem.Settings settings, Config config){
        super(new PriorityGenerator() {
            @Override
            public int gen(Object message) {
                if(message.equals("张三")){
                    return 0;
                }else if(message.equals("李四")){
                    return 1;
                }else if(message.equals("王五")){
                    return 2;
                }else {
                    return 3;
                }
            }
        });
    }
}
class priorityActor extends UntypedActor{
    @Override
    public void onReceive(Object message) throws Exception{
        System.out.print(message+"---\n");
    }
}
class Test1202 {
    public static void main(String[] args) throws Exception{

        Config firstConfig = ConfigFactory.parseFile(new File("./conf/application.conf")).withFallback(ConfigFactory.load());
        ActorSystem system= ActorSystem.create("sys1",firstConfig);
        ActorRef ref= system.actorOf(Props.create(priorityActor.class).withMailbox("msgprio-mailbox"),"priorityActor");
       Object[] message={"王五","张三","李四","小二"};
       for(Object msg:message){
           ref.tell(msg,ActorRef.noSender());
       }
    }
}





![图片说明](https://img-ask.csdn.net/upload/201812/03/1543848875_367858.png)图片说明
图片说明

  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥15 多电路系统共用电源的串扰问题
    • ¥15 shape_predictor_68_face_landmarks.dat
    • ¥15 slam rangenet++配置
    • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
    • ¥15 对于相关问题的求解与代码
    • ¥15 ubuntu子系统密码忘记
    • ¥15 信号傅里叶变换在matlab上遇到的小问题请求帮助
    • ¥15 保护模式-系统加载-段寄存器
    • ¥15 电脑桌面设定一个区域禁止鼠标操作
    • ¥15 求NPF226060磁芯的详细资料