- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
假设我有一个以集合作为值的并发映射:
Map<Integer, List<Integer> map = new ConcurrentHashMap<>();
map.putIfAbsent(8, new ArrayList<>());
然后我按如下方式更新值:
map.computeIfPresent(8, (i, c) -> {
c.add(5);
return c;
});
我知道 computeIfPresent
整个方法调用是原子执行的。然而,考虑到这个映射被多个线程同时访问,我有点担心对底层集合所做的修改的数据可见性。在这种情况下,调用 map.get
我的问题是,如果更改是在 computeIfPresent
方法调用中执行的,那么在调用 map.get
时,列表是否会在其他线程中可见。
请注意,我知道如果我在执行更新操作之前引用列表,则列表的更改将不可见。如果我在更新操作后引用列表(通过调用 map.get
),我不确定列表的更改是否可见。
我不确定如何解释这些文档,但在我看来,先行发生关系将保证在这种特定情况下底层集合的更改可见
More formally, an update operation for a given key bears a happens-before relation with any (non-null) retrieval for that key reporting the updated value
最佳答案
该方法被记录为原子
的事实并不意味着可见性
(除非这是文档的一部分)。例如,为了使这个更简单:
// some shared data
private List<Integer> list = new ArrayList<>();
public synchronized void addToList(List<Integer> x){
list.addAll(x);
}
public /* no synchronized */ List<Integer> getList(){
return list;
}
我们可以说addToList
确实是原子的,一次只能有一个线程调用它。但是一旦某个线程调用 getList
- 根本无法保证 visibility
(因为要建立它,it has to happens on the same lock)。因此,可见性是之前发生的事情,computeIfPresent
文档对此根本没有说明。
相反,类文档说:
Retrieval operations (including get) generally do not block, so may overlap with update operations (including put and remove).
这里的关键点显然是overlap,所以一些其他线程调用get
(从而获得那个List
),可以看到List
处于某种状态;不一定是 computeIfPresent
开始的状态(在您实际调用 get
之前)。一定要进一步阅读以理解一些实际上可能意味着什么。
现在是该文档中最棘手的部分:
Retrievals reflect the results of the most recently completed update operations holding upon their onset. More formally, an update operation for a given key bears a happens-before relation with any (non-null) retrieval for that key reporting the updated value.
再读一遍关于completed 的句子,它说的是当一个线程get
时你唯一能读到的是last completed 说明 List 所在的位置。现在下一句话说在两个 Action 之间建立了一个发生在之前。
想一想,在两个后续 操作之间建立了一个happens-before
(如上面的同步示例);所以在内部,当你更新一个 Key
时,可能会有一个不稳定的书面信号表明更新已经完成(我很确定它不是这样完成的,只是一个例子)。为了让 happens before 真正起作用,get
必须读取那个 volatile 并查看写入它的状态;如果它看到该状态,则意味着发生在之前;我想这实际上是通过其他一些技术强制执行的。
因此,为了回答您的问题,所有调用 get
的线程都将看到发生在该键上的 last completed action
;在你的情况下,如果你能保证订单,我会说,是的,它们将是可见的。
关于Java ConcurrentHashMap.computeIfPresent 值修改可见性,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52577524/
我在 Mac OsX 10.11 上使用 Xcode 7.0.1 (7A1001) 我使用 carthage 0.9.2 通过以下购物车文件下载reactivecocoa github“Reactiv
我正在将一个对象从属性“模型”(我从 Laravel 中的 Blade 属性模型中获得)分配给数据属性模型。后来数据属性模型发生变化,因为它绑定(bind)到表单输入字段。但 Prop “模型”也发生
当我更新数组内对象的属性然后作为组件的 Prop 传递时,在 svelte 中触发 react 性的正确方法是什么? let items = [{ id: 1, name: 'first'
我是 DRY principle 的坚定拥护者: Every piece of knowledge must have a single, unambiguous, authoritative rep
我正在实现一个需要以下功能的线程: 及时响应终止请求 推送消息 在等待消息时保持对 SendMessage 请求的响应 我对消息泵的初始实现使用了 GetMessage,如下所示: while not
在我的应用程序中,用户获得了一份已到达她的文档列表,并且可以对每个文档执行操作。 文件是分批提交的,当这种情况发生时,列表会增加。这一切都很好,这是预期的行为,但最好有一个按钮“暂停实时数据”,它会忽
我有一个属性为 的数据对象 displaySubtotal 我可以通过以下方式更新该属性的值: data.displaySubtotal = numPad.valueAsAString(); 我的方法
我需要一个垂直 slider 输入。由于内置的 sliderInput 函数无法做到这一点,因此我选择自己实现。根据this thread可以 (I) 使用 CSS 旋转 sliderInput
我正在从自定义用户权限管理系统迁移到 Alanning:roles v2.0 .我有一个非常基本的结构: 基本用户 用户组,每个用户组都有特定的设置。我将它们存储在一个“组”集合中。 管理群组的用户的
Shiny 中的响应式(Reactive)表达式将更改传播到需要去的地方。我们可以使用 isolate 来抑制一些这种行为。 ,但是我们可以抑制基于我们自己的逻辑表达式传播的更改吗? 我给出的例子是一
是否有(或可能有) react 性 Parsec (或任何其他纯函数式解析器)在 Haskell 中? 简而言之,我想逐个字符地为解析器提供数据,并获得与我提供的足够多的结果一样多的结果。 或者更简单
HTML(JADE) p#result Lorem ipsum is javascript j s lo 1 2 4 this meteor thismeteor. meteor input.sear
我有一个被导入函数更改的对象。 https://svelte.dev/repl/e934087af1dc4a25a1ee52cf3fd3bbea?version=3.12.1 我想知道如何使我的更改反
我有一个YUV 420半平面格式的图像,其中字节以这种方式存储: [Y1 Y2 ... [U1 V1.... Yk Yk+1...] Uk' Uk'+1] 其中Y平面的大小是UV平面的两倍,并
如何使用 ReactiveCocoa 订阅从 NSMutableDictionary 添加和删除的对象?另外,我想在它发生变化时广播通知。我的猜测是可以使用 RACMulticastConnectio
我正在构建一个带有多个选项卡的应用程序,其中一些选项卡涉及过多的计算,而另一些选项卡的计算速度很快。一个允许用户在 react 性或手动更新之间进行选择的复选框,与“刷新”按钮结合使用,将是理想的选择
我知道您可以在获取集合时使用 reactive: false 关闭 react 性。如何在内容可编辑区域内的集合字段中实现相同的效果?示例: Template.documentPage.events(
我想在 z3 中表示一个哈希函数,比如 SHA(x)。在做了一些研究之后,似乎 z3 不能很好地支持注入(inject)性,所以我不能有像这样的约束(虽然我意识到这并不是严格意义上的碰撞,但作为一种启
我正在解决一个问题,我想在仪表板中将数据显示为图表(通过 perak:c3 )和表格(通过 aslagle:reactive-table )。我的问题是数据是从 MongoDB 中的集合中提取的,它的
我的 ViewModel 中有这个函数,它返回一个信号,但内部 block 不起作用,我尝试添加断点,但它没有中断。这是我的代码。 func executeLoginAPI() -> RACSigna
我是一名优秀的程序员,十分优秀!