在ConcurrentHashMap的javadoc中如下:
检索操作(包括get)一般不会阻塞,因此可能与更新操作重叠(包括put和remove) . 检索反映了最近完成的更新操作的结果 . 对于诸如putAll和clear之类的聚合操作,并发检索可能反映仅插入或删除某些条目 . 类似地,Iterators和Enumerations在迭代器/枚举的创建时或之后的某个时刻返回反映哈希表状态的元素 . 它们不会抛出ConcurrentModificationException . 但是,迭代器设计为一次只能由一个线程使用 .
这是什么意思?如果我尝试同时使用两个线程迭代 Map 会发生什么?如果我在迭代时放置或删除 Map 中的值,会发生什么?
5 回答
您可以使用此类测试两个访问线程,一个变更
ConcurrentHashMap
的共享实例:不会抛出异常 .
在访问者线程之间共享相同的迭代器可能会导致死锁:
一旦你开始在访问器和mutator线程中共享相同的
Iterator<Map.Entry<String, String>>
,java.lang.IllegalStateException
将开始弹出 .这意味着您不应在多个线程之间共享迭代器对象 . 创建多个迭代器并在不同的线程中同时使用它们很好 .
This可能会给你一个很好的见解
关于这个:
这意味着,虽然在两个线程中使用ConcurrentHashMap生成的迭代器是安全的,但它可能会在应用程序中导致意外结果 .
这意味着您从
ConcurrentHashMap
获得的每个迭代器都被设计为由单个线程使用,不应传递 . 这包括for-each循环提供的语法糖 .如果每个线程都使用它自己的迭代器,它将按预期工作 .
如果你这样做,保证事情不会中断(这是
ConcurrentHashMap
中"concurrent"的意思) . 但是,无法保证一个线程将看到另一个线程执行的映射更改(无需从映射中获取新的迭代器) . 迭代器保证在创建时反映 Map 的状态 . 进一步的变化可能会反映在迭代器中,但它们并非必须如此 .总之,一个声明就像
几乎每次看到它都会很好(或至少是安全的) .
这意味着您不应该尝试在两个线程中使用相同的迭代器 . 如果你有两个线程需要迭代键,值或条目,那么它们每个都应该创建并使用它们自己的迭代器 .
如果违反这条规则会发生什么情况并不完全清楚 . 您可能会遇到令人困惑的行为,就像您(例如)两个线程尝试从标准输入读取而不进行同步一样 . 您还可以获得非线程安全行为 .
但如果两个线程使用不同的迭代器,你应该没问题 .
这是一个单独的问题,但你引用的javadoc部分足以回答它 . 基本上,迭代器是线程安全的,但是 it is not defined 是否会看到迭代器返回的对象序列中反映的任何并发插入,更新或删除的影响 . 实际上,它可能取决于更新发生在 Map 中的位置 .