Hazelcast分区计数和线程并发
在Master Hazelcast电子书“17.4.1.分区感知操作”下，它指出：
要执行分区感知操作，需要创建操作线程数组。
单个操作线程对多个分区执行操作；
每个分区只属于1个操作线程。
忽略备份和近缓存，当我创建一个IMap实例时，这是否意味着我只能有一个并发的put/get操作在整个集群的每个map分区上执行？进一步说，如果我附加了一个MapStore，这是否意味着我只能对我的后端数据库运行271个并发操作，因为没有办法创建异步MapStore？
我问这个问题的原因是我有一个高度并发的Web应用程序，并且我最近将数据存储切换为在它前面使用Hazelcast IMap运行。应用程序接受数千个并发连接，几乎每个请求都至少从分布式映射执行一个get操作。我看到了很多这样的错误：
com.hazelcast.core.OperationTimeoutException：20000 ms无响应。正在中止调用！调用{ServiceName='Hz:Impl:MapService“,op=com.hazelcast.map.impl.operation.getOperation{identityHash=1003806362,ServiceName='Hz:Impl:MapService”,PartitionID=244,ReplicaIndex=0,Callid=55212219,InvocationTime=1462913274676（Tue 5月10日20:47:54 UTC 2016）,WaitTimeout=-1,CallTimeout=10000,Name=...,Name=...},PartitionID=244,ReplicaIndex=0备份-预期：0备份-已完成:0
这是否仅仅是由于MapStore在分区线程试图从数据库获取时阻塞了它？我还应该注意到，虽然它说20000ms没有响应，但20秒还没有过去。
我正在Java8上运行Hazelcast 3.6.2。
共有1个答案
当我创建一个IMap实例时，这是否意味着我只能在集群中的每个映射分区上执行一个并发的put/get操作？
正确。因此，映射a和映射b的分区25可能正忙于处理映射b的操作，因此映射a的操作需要等待。
进一步说，如果我附加了一个MapStore，这是否意味着我只能对我的后端数据库运行271个并发操作，因为没有办法创建异步MapStore？
这是否仅仅是由于MapStore在分区线程试图从数据库获取时阻塞了它？我还应该指出，虽然它说20000毫秒没有响应，但20秒还没有过去。
这很可能是原因。
-
问题内容： 如何区分正在运行的Java线程和本机线程？ 在Linux中，每个子进程都有一个父进程，他们说0是所有进程的父进程，所有分叉的Java线程中都会有一个父线程吗？ 我如何知道哪个Java线程与OS线程相关（如果Java线程派生了本机进程线程）。 Java线程和OS线程有任何命名约定吗？ 可以从另一个Java代码中挂起或杀死正在运行的Java线程吗？ 问题答案： 在Linux上，Java线程
-
我设置了一个Spring集成流程来处理一个有3个分区的主题，并将侦听器容器的并发性设置为3。正如所料，我看到三个线程处理来自所有3个分区的批处理。然而，我发现在某些情况下，一个侦听器线程可能处理包含来自多个分区的消息的单个批处理。在kafka中，我的数据是按id划分的，因此它可以与其他id同时处理，但不能在另一个线程上与相同的id一起处理(我很惊讶地发现这种情况正在发生)。通过阅读文档，我认为每个
-
我需要实现线程安全的集群范围计数器map，所以我使用Hazelcast使它成为集群范围的，但不知道如何使它成为线程安全的，我尝试使用AtomicInteger，但看起来像是当一个线程反序列化AtomicInteger以进行增量时，其他线程可能会进行增量并将其放回map中。所以你能给我提点建议吗？某种最佳实践？我认为我可以使用分布式锁实现它，但不确定这是最好的解决方案。
-
我对Spark相当陌生，所以也许我只是错过或误解了一些基本的东西。如有任何帮助，不胜感激。
-
有没有办法使用laravel使这个查询工作？DB：：原始或雄辩的用法并不重要。 以下是我尝试过的，但无法获得正确的输出： 这将返回这样的东西，我想解决这个问题： 我只想数到15。
-
我尝试了一些具有分析功能的示例，并创建了一个sql fiddle来理解分区上的count distinct by Clause，这就是我的SQLFiddle。 如果查看结果集，我会认为第三行的valcount为1，但它是2，不确定为什么会这样。