这是交易。我有一个 HashMap ，其中包含我称为“程序代码”的数据，它存在于一个对象中，如下所示:
Class Metadata
{
private HashMap validProgramCodes;
public HashMap getValidProgramCodes() { return validProgramCodes; }
public void setValidProgramCodes(HashMap h) { validProgramCodes = h; }
}
我有很多很多读取器线程，每个线程都会调用一次 getValidProgramCodes()，然后将该 HashMap 用作只读资源。
到目前为止一切顺利。这就是我们变得有趣的地方。
我想放入一个计时器，它每隔一段时间生成一个新的有效程序代码列表(不管如何)，并调用 setValidProgramCodes。
我的理论——我需要帮助来验证——是我可以继续按原样使用代码，而无需进行显式同步。它是这样的: 在更新 validProgramCodes 时，validProgramCodes 的值总是好的——它是指向新 HashMap 或旧 HashMap 的指针。 这是一切都取决于的假设。拥有旧散列图的读者是可以的；他可以继续使用旧值，因为在他释放它之前它不会被垃圾回收。每个读者都是短暂的；它很快就会死去，并被一个新的取而代之并获得新的值(value)。
这站得住脚吗？我的主要目标是在绝大多数没有更新发生的情况下避免昂贵的同步和阻塞。我们大约每小时只更新一次，读者不断地进进出出。
最佳答案
这是一个线程关心另一个线程在做什么的情况吗？然后 JMM FAQ有答案:
Most of the time, one thread doesn't care what the other is doing. But when it does, that's what synchronization is for.
针对那些说 OP 的代码按原样是安全的人的回应，考虑一下:Java 的内存模型中没有任何东西可以保证在启动新线程时该字段将刷新到主内存。此外，只要更改在线程中检测不到，JVM 就可以自由地重新排序操作。
从理论上讲，读取器线程不能保证看到对 validProgramCodes 的“写入”。在实践中，他们最终会，但你不能确定什么时候。
我建议将 validProgramCodes 成员声明为“volatile”。速度差异可以忽略不计，并且无论引入何种 JVM 优化，它都将保证您的代码现在和将来的安全。
这里有一个具体的建议:
import java.util.Collections;
class Metadata {
private volatile Map validProgramCodes = Collections.emptyMap();
public Map getValidProgramCodes() {
return validProgramCodes;
}
public void setValidProgramCodes(Map h) {
if (h == null)
throw new NullPointerException("validProgramCodes == null");
validProgramCodes = Collections.unmodifiableMap(new HashMap(h));
}
}
除了用 unmodifiableMap 包装它之外，我还在复制映射 (new HashMap(h))。这使得即使 setter 的调用者继续更新映射“h”也不会改变的快照。例如，他们可能会清除 map 并添加新条目。
在风格上，通常最好用 List 和 Map 等抽象类型声明 API，而不是像 ArrayList 这样的具体类型和 HashMap。 如果具体类型需要更改(就像我在这里所做的那样)，这会在将来提供灵 active 。
将“h”分配给“validProgramCodes”的结果可能只是对处理器缓存的写入。即使在新线程启动时，“h”对新线程也是不可见的，除非它已被刷新到共享内存。除非有必要，否则良好的运行时将避免刷新，使用 volatile 是表明这是必要的一种方式。
假设以下代码:
HashMap codes = new HashMap();
codes.putAll(source);
meta.setValidProgramCodes(codes);
如果 setValidCodes 只是 OP 的 validProgramCodes = h;，编译器可以像这样自由地重新排序代码:
1: meta.validProgramCodes = codes = new HashMap();
2: codes.putAll(source);
假设在编写器第 1 行执行后，读取器线程开始运行此代码:
1: Map codes = meta.getValidProgramCodes();
2: Iterator i = codes.entrySet().iterator();
3: while (i.hasNext()) {
4: Map.Entry e = (Map.Entry) i.next();
5: // Do something with e.
6: }
现在假设writer线程在reader的第2行和第3行之间的map上调用了“putAll”，Iterator底层的map经历了一次并发修改，抛出了一个runtime exception——一个非常断断续续的，看似莫名其妙的runtime exception在测试期间从未产生过。
任何时候你有一个线程关心另一个线程在做什么，你必须有某种内存屏障来确保一个线程的操作对另一个线程可见。如果一个线程中的事件必须在另一个线程中的事件之前发生，您必须明确指出。否则没有任何保证。实际上，这意味着 volatile 或 synchronized。
不要吝啬。错误程序无法完成工作的速度有多快并不重要。此处显示的示例简单而人为，但请放心，它们说明了现实世界中的并发错误，由于其不可预测性和平台敏感性，这些错误非常难以识别和解决。
关于Java并发场景——需要同步还是不需要？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/300316/
当我使用Bundler时，是否需要在我的Gemfile中将其列为依赖项？毕竟，我的代码中有些地方需要它。例如，当我进行Bundler设置时:require"bundler/setup" 最佳答案 没有。您可以尝试，但首先您必须用鞋带将自己抬离地面。 关于ruby-我需要将Bundler本身添加到Gemfile中吗？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/4758609/
我注意到像bundler这样的项目在每个specfile中执行requirespec_helper我还注意到rspec使用选项--require，它允许您在引导rspec时要求一个文件。您还可以将其添加到.rspec文件中，因此只要您运行不带参数的rspec就会添加它。使用上述方法有什么缺点可以解释为什么像bundler这样的项目选择在每个规范文件中都需要spec_helper吗？ 最佳答案 我不在Bundler上工作，所以我不能直接谈论他们的做法。并非所有项目都checkin.rspec文件。原因是这个文件，通常按照当前的惯例，只
我实际上是在尝试使用RVM在我的OSX10.7.5上更新ruby，并在输入以下命令后:rvminstallruby我得到了以下回复:Searchingforbinaryrubies,thismighttakesometime.Checkingrequirementsforosx.Installingrequirementsforosx.Updatingsystem.......Errorrunning'requirements_osx_brew_update_systemruby-2.0.0-p247',pleaseread/Users/username/.rvm/log/138121
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见，例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Rubysyntaxquestion:Rational(a,b)andRational.new!(a,b)我正在阅读ruby镐书，我对创建有理数的语法感到困惑。Rational(3,4)*Rational(1,2)产生=>3/8为什么Rational不需要new方法(我还注意到例如我可以在没有new方法的情况下创建字符串)？
什么是ruby的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目，Java开发。基于数据库增量日志解析，提供增量数据订阅&消费。Git地址：https://github.co
这篇文章是继上一篇文章“Observability：从零开始创建Java微服务并监控它（一）”的续篇。在上一篇文章中，我们讲述了如何创建一个Javaweb应用，并使用Filebeat来收集应用所生成的日志。在今天的文章中，我来详述如何收集应用的指标，使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值，然后一切都回到一个请求。这也意味着这些指标可能不准确，你还想提取最小/