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
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
关于akka的mailbox的size问题
在akka1.x中无论在actor内部还是外部提供了一个查询mailbox size的方法。但是在akka2.0中由于一系列的原因这一个方法被删除了。 那么查询maibox size会存在什么问题呢? 1,需要花费O(n)的时间,在queue并发大的情况下可能会很慢;) 2,并不需要精确计算size; 3,限制了扩张性; 4,在你得到size的时候,这个时候实际的size可能已经发生
学习akka之邮箱
学习akka之邮箱
Akka 邮箱
邮箱 一个Akka Mailbox保存发往某个Actor的消息。通常每个Actor都拥有自己的邮箱,但也有例外,例如使用BalancingPool的所有路由子(routee)共享同一个邮箱实例。 邮箱选择 为actor指定一个消息队列类型 为某个特定类型的actor指定一个特定类型的消息队列是有可能的,只要通过actor扩展RequiresMessageQueue参数化特质即可。下面是一个...
为什么linux下多线程编程,每次执行结果都不一样
#include <pthread.h> #include <stdlib.h> #include <stdio.h> #include <string.h> #include <errno.h> #include <iostream> using namespace std; voi...
程序每次运行结果不一样
<br />今天做软件更新图标的时候,遇到的一个看起来很奇怪的问题,便是显示的图标每次都不一样。后来查了半天,发现是自己写的代码里面,寻找图标的索引值没有初始化的结果,所以导致每次看起来的图标均不一样。<br />这些细节问题看似很不经意,却比较容易引用未知的错误。告戒自己以后写代码一定要养成好习惯!做一次宝贵的经验记下吧。
用深度学习每次得到的结果都不一样,怎么办?(Python)
https://www.leiphone.com/news/201706/zt4Dm491Ol58C8Mc.html?utm_source=tuicool&utm_medium=referral 神经网络算法利用了随机性,比如初始化随机权重,因此用同样的数据训练同一个网络会得到不同的结果。 初学者可能会有些懵圈,因为算法表现得不太稳定。但实际上它们就是这么设计的。随机初始化可以让网
tensorflow中导入相同模型,每次传入图片的输出预测值不一样(预测值差很多)
产生问题原因:导入模型后,传入神经网络的dropout=1.0未生效。故原网络中的dropout默认值=0.9生效,所以每次运行就会dropout掉一些神经元,所以每次输出结果肯定不一样。 为何传入dropout=1.0未生效,解决如下: tensorflow导入模型有很多方法,其中有两种方式: 这种方法虽简单,但是要在代码中重新写出训练网络的结构(该方法要写在重写的网络结构之后) ①将已经定...
Akka学习笔记(五):Akka与Java的内存模型
Akka学习笔记(五):Akka与Java的内存模型 Akka简化了编写并发软件的过程,本文主要讨论Akka如何在并发应用中访问共享内存。 Java内存模型 Java5之前的JMM是相当混乱的。多线程访问共享内存很有可能会得奇怪的结果,如: 可见性问题,无法及时看到其他线程写入的值指令乱序,观测到其他线程不可能的行为 从Java 5的JSR 133的实现,很多问题就解
Pytorch evaluation每次运行结果不同
这两天跑测试图时,发现用同样的model,同样的测试图,每次运行结果不同; 经过漫长的debug发现,在net architure中有dropout,如下(4):       (conv_block): Sequential(         (0): ReflectionPad2d((1, 1, 1, 1))         (1): Conv2d(256, 256, kernel_size...
Android使用AES加密解密准确版下载。每次加密的密文结果不一样?能加密但解密不出原文?看这里就对了
使用AES方式加密解密,密文唯一,解密正确。
tensorflow保持每次训练结果一致
在用tensorflow构建神经网络的时候,有很多随机的因素,比如参数的随机初始化: 正态分布随机变量tf.random_normal([m,n]),均匀分布的随机变量tf.random_uniform([m,n]),还有在从tfrecord读取数据时,也会随机打乱数据。 那么由于这些随机的操作,即使是在输入数据完全一样的情况下,每次训练的结果也不一样,那么如果想要使得每次训练的结果一致,应该怎...
RSA加密为什么每次加密的结果不一样
JAVA写RSA加密,私钥都是一样的,公钥每次加密的结果不一样跟对数据的padding(填充)有关。 1、Padding (填充)属性定义元素边框与元素内容之间的空间。 2、padding 简写属性在一个声明中设置所有内边距属性。设置所有当前或者指定元素内边距属性。该属性可以有1到4个值。 3、当元素的 Padding(填充)(内边距)被清除时,所&amp;quot;释放&amp;quot;的区域将会受到元素背景颜色的填充。 4、单...
使用StatsD, Graphite, Grafana, Kamon搭建可用于JVM项目的可视化性能监控系统
原文地址:http://skaka.me/blog/2015/07/21/kamon-statsd-graphite-grafana-introduction/ 1. 什么是性能监控系统 这里说的性能监控系统,主要侧重点是监控应用系统的性能。 说直白点就是每个业务(例如注册,登录)的请求响应时间,请求次数等信息。 操作系统的监控不是这里的重点,因为业界已经有许多相当成熟的基于L
AES加密算法在linux下相同输入每次加密结果都不同的问题
现象描述: 在 windows 操作系统下加解密正常,但部署到 linux 环境中相同的输入加密结果不正确,并且每次运行返回的结果都不同。 修改后的代码:            KeyGenerator kgen = KeyGenerator.getInstance("AES");            //需手动指定 SecureRandom 随机数生成规则            S
对于AKKA中actor的一点个人理解
对于AKKA中actor的一点个人理解 Actor是什么 Actor和线程的区别 Actor是如何执行的 不要阻塞一个Actor 慎用Actor的ask方法 thoughtput的一点思考 Actor是什么 曾经看到知乎上有人提过actor就是cpu上的时间片,这种说法非常贴切。Actor之间通过消息进行通讯,一切都是异步的。可以说Actor就像现实生活中的一群人,他们各司...
有关kmeans训练结果不一样的问题
最近一直在实现一篇注释轨迹的文章,里面要用到kmeans聚类方法,先在网上随便找了一个kmeans程序进行聚类,结果发现时间太长,最后问了作者,作者采用的是vlfeat的系列程序,里面的kmens++程序速度较一般的来说比较快,网址如下:   http://www.vlfeat.org/index.html       实验中发现,如果聚类的特征都是从一个图片上得来,或者说都是一类相像的图片,
Scala并发编程模型AKKA
关键字 1)final 如果方法不想被重写可以使用final关键字进行修饰 用final修饰的: 类:类不能被继承 方法:不能被重写 val 2)type 别名设置 使我们的程序变得更灵活 T trait b { type T def go(str:T)={ println(str) } } object test extends b { override type T ...
scala笔记和akka笔记
原文地址:http://my.oschina.net/jingxing05/blog/290567 非阻塞的程序 应该保障的一些特性 : 等待无关性wait-free:能确保每次的调用在有限的步数之内完成,不管其他调用的步骤有多少。杀掉几个线程锁无关性lock-free:执行这段程序的某些线程会被延迟,但必须确保至少有一个线程能持续步骤到执行完毕。这一点需防止可能出现的饿
Akka Actor的异步与阻塞用法
Akka的actor的调用方式与机制,不同的调用方式,效果不同。
java并发编程多个线程为什么执行的先后顺序不一样!
jvm为了使得处理器内部的运算单元能尽量被充分利用, 处理器可能会对输入代码进行乱序执行(Out-Of-Order Execution)优化,处理器会在计算之后将乱序执行的结果重组,保证该结果与顺序执行的结果是一致的,但并不保证程序中各个语句计算的先后顺序与输入代码中的顺序一致,因此,如果存在一个计算任务依赖另外一个计算任务的中间结果,那么其顺序性并不能靠代码的先后顺序来保证 摘自:《深入理解...
akka学习教程(五) inbox消息收件箱
我们知道,整个akka的actor系统是通过消息进行传递的,之前的几个教程都是通过一个actor来给另一个actor发消息。其实还可以使用inbox消息收件箱来给某个actor发消息,并且可以进行交互。package akka;import akka.actor.*; import akka.event.Logging; import akka.event.LoggingAdapter; impor
有趣的加密算法------每次加密后的数据都不一样
最近, 碰到这样一个实际问题, 对同一个串采用同一个加密算法, 每次的结果都不一样, 但解密后, 又都能正确还原, 挺有意思的。        这是个封装了的加密算法, 我没有直接去看内部实现的源码, 但如上特性是很好实现的, 我也想到了实现方法。        有兴趣的朋友可以想一下, 怎么实现如上特性。
为什么RSA公钥每次加密得到的结果都不一样?
&amp;lt;&amp;lt;OpenSSL和Python实现RSA Key公钥加密私钥解密&amp;gt;&amp;gt;中提到,发现使用RSA公钥对同一数据加密,每次的结果都不一样。百度一下,很多人都有这个疑问,但并没有看到详细的分析解答,即使有人说是因为padding填充的原因,也都是一带而过。 为什么私钥对同一数据进行签名加密的结果是一样的,使用公钥进行加密就不一样了呢? 是的,这个问题跟对数据的padding即填...
Akka学习笔记:测试Actors
在《Akka学习笔记:日志》文章中介绍了Akka的日志功能。本文主要介绍如何测试Actors。 文章目录 [hide] 1 测试Akka 1.1 1, 2 - 给Actor发送消息 1.2 3、检查Actors的内部状态 1.3 4、检查日志消息 1.4 5、测试带有构造参数的Actors 2 关闭ActorSystem 测试Akka   
23、 聊聊akka(三) 集群&持久化
Akka集群支持去中心化的基于P2P的集群服务,没有单点故障(SPOF)问题,它主要是通过Gossip协议来实现。对于集群成员的状态,Akka提供了一种故障检测机制,能够自动发现出现故障而离开集群的成员节点,通过事件驱动的方式,将状态传播到整个集群的其它成员节点。 集群概念 节点(node):集群中的逻辑成员。允许一台物理机上有多个节点。由元组hostname:port:uid唯一确...
ElasticSearch6.2.4(15)——解答集群出现的在同一个index中用同样的搜索条件,每次返回的排序都不一样问题!
1.这次小编在搭建集群后发现每次搜索的时候都发现排序都不一样,并且打印出score也不一样,如图发现规律没,这种只有两种情况,而我的有5个主节点并且每个主节点有个副节点,...
Akka简单的性能测试
因为最近工作的关系,要把异步任务从应用服务器中拆分到专门的异步处理服务器中.方案一是采用MQ的方式将任务消息发出,在服务端进行处理,如下图所示: 这种方案是采用MQ作为中间的媒介,在服务端采用线程池异步处理任务,处理完成之后将结果发送到MQ中,客户端采用侦听的方式得到结果继续进行处理。 这种方案的不足是,可能在某些需求的情况下,需要将结果存放到共享的HashMap或者Threadlocal
对Akka Future的理解(一)
《AkkaJava-v2.2.5》对Future描述如下: 4.1 Futures 4.1.1 Introduction In the Scala Standard Library, a Future is adata structure used to retrieve the result of some concurrent operation. This result can
caffe训练模型后,使用模型测试的分类结果全部都是相同的
从训练的输出可以看出,accuracy非常低,loss一直不收敛,所以使用这个训练出来的模型的分类结果都一样,因为训练过程中,机器根本没有学到东西~~ 两种原因: 1、网络结构参数不对或者缺少   2、数据量太少 我使用了相同的网络去训练不同量的数据,10000+数据迭代10000次的效果好了很多,5000的数据量迭代4000次就没学到东西~
Linux操作系统下每次AES加密结果不一致的原因
定位在生成KEY的方法上,如下: public static SecretKey getKey (String strKey) { try { KeyGenerator _generator = KeyGenerator.getInstance( "AES" ); _generator
[自用门户]加密解密,每次生成的结果不一样(Base64Utils+RSAUtils)
Base64Utils+RSAUtils+EncryptPropertyPlaceholderConfigurer(加密解密类) /* Copyright (C) 2017 Shanghai Huizhao e-Bidding Services Co., Ltd. All rights reserved. Author: WGY Version: 1.0 Created Time:
随机数生成算法,每一次生成都不一样
项目中要用到一个随机数生成算法,但是每一次生成间隔时间很短,还要保证每一次生成的随机数都不相同,于是就想到了利用当前时间的毫秒作为随机数种子来生成。 #include #include // for gettimeofday() #include // for random() using namespace std; unsigned int getRandomNum(); int
Akka学习笔记:ActorSystem(调度)
调度   正如你在ActorSystem中的API看到的,如下: 1 //Light-weight scheduler for running asynchronous tasks after some deadline in the future. 2 def   scheduler : Sch
为什么结果都不一样
我在网上找了几个不同版本的3DES算法代码,但是为什么加密,解密的结果都不一样.rn用版本A加密的结果就不能用B还原?rn有谁知道是为什么?rn
Akka性能测试
Akka承诺高并发。那么有什么更好的方式来模拟呢?,让它处理1000万信息花费多少时间,使用普通硬件和软件并且没有任何低级别的微调。这个例子使用Akka产生1000万条信息,计算处理它们所花费的时间。该程序演示了路由的概念,roundrobinrouter是用于将负载分发到一组worker工作者上面,类似负载平衡概念。 运行的硬件:英特尔酷睿4核 4 GB RAM的iMac,分配1024M给JV
java中使用akka手记一
什么是actor? Actor模型在并发编程中是比较常见的一种模型。很多开发语言都提供了原生的Actor模型。例如erlang,scala等。它由Carl Hewitt于上世纪70年代早期提出,目的是为了解决分布式编程中一系列的编程问题。Actor模型的本质已经被强调了无数遍:万物皆Actor。Actor之间只有发送消息这一种通信方式。一个Actor如何处理多个Actor的请求呢?它先建立一
一台机器(操作系统)能启动多个JVM
悲剧啊,今天才知道一台机器(操作系统)能启动多个JVM进程,各个JVM进程有独自的数据空间和代码空间,互不影响 并且每调用java命令之后(执行启动类的main函数),就是启动一个JVM实例 怪不得之前发现,一个Tomcat启动之后,其他的Tomcat目录下的的关闭脚本可以关闭之前起的Tomcat,看来要学的还有很多啊
java多线程-线程安全问题-jvm内存模型
jvm内存模型jvm设计自己的内存模型的优缺点?与操作系统的内存有何联系?jvm内存模型与多线程的关系 jvm设计自己的内存模型的优缺点?与操作系统的内存有何联系? jvm内存模型与多线程的关系 ...
170719 Keras重复运行结果不一致问题
Github-2743 Github-2479 不同版本的keras,对同样的代码,得到不同结果的原因总结 用深度学习每次得到的结果都不一样,怎么办? 指定随机数+Shuffle=False方法(认为模型结果的不确定性与采样训练时的随机种子有关) import numpy as np np.random.seed(1337) 万能重启大法(找不到原因,重启试试) Th
21、聊聊akka(一)使用及集群调用(负载)
问到:akka的线程模型 为actor模型,那actor模型具体是怎么样的呢? 一种类似于协程的事件(消息)驱动? AKKA提供一种Actor并发模型,其粒度比线程小很多,这意味着你可以在项目中使用大量的Actor。 Akka提供了一套容错机制,允许在Actor出错时进行一些恢复或者重置操作 AKKA不仅可以在单击上构建高并发程序,也可以在网络中构建分布式程序,并提供位置透明的Act...
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 akka java 学习 nlp学习指导