Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何使 ScheduledExecutorService 在计划任务取消时自动终止
我正在使用一个ScheduledExecutorService如果网络连接已打开超过几个小时 则关闭该连接 然而 在大多数情况下 网络连接在超时之前就关闭了 所以我取消了ScheduledFuture 在这种情况下 我还希望执行程序服务终止
Java
Multithreading
concurrency
javautilconcurrent
Java ServiceExecutor 终止条件
我对 java 执行器很陌生 我正在使用 Java 的 ExecutorService 启动多个线程来处理数据 Executor executor Executors newFixedThreadPool poolSize for int
Java
Multithreading
ExecutorService
javautilconcurrent
scala.concurrent.blocking - 它实际上做了什么?
我花了一段时间学习 Scala 执行上下文 底层线程模型和并发性的主题 你能解释一下通过什么方式吗scala concurrent blocking 调整运行时行为 and 可以提高性能或避免死锁 如中所述scaladoc http www
scala
concurrency
javautilconcurrent
在java中实现你自己的阻塞队列
我知道这个问题之前已经被问过并回答过很多次了 但我只是无法根据互联网上找到的示例找出窍门 例如this http tutorials jenkov com java concurrency blocking queues html or t
Java
Multithreading
synchronization
javautilconcurrent
BlockingQueue
内存一致性 - Java 中的happens-before关系[重复]
这个问题在这里已经有答案了 在阅读有关内存一致性错误的 Java 文档时 我发现与创建 发生 之前 关系的两个操作相关的点 当语句调用时Thread start 每个具有 与该语句发生之前的关系也有一个 与 new 执行的每个语句之间发生的
Java
javautilconcurrent
happensbefore
Java 8:并行 FOR 循环
我听说 Java 8 提供了很多关于并发计算的实用程序 因此我想知道并行给定 for 循环的最简单方法是什么 public static void main String args Set
Java
forloop
concurrency
javautilconcurrent
concurrentprogramming
Java Executor 根据 CPU 和 RAM 使用情况调整线程池
我的应用程序使用 Executor 为大量任务提供线程池 通过分析和基准测试 我确定当每个核心有多个线程时 我的应用程序运行速度最快 一个好的启发式方法是从每个核心 4 个线程开始 不断变化 直到达到 gt 90 CPU 或 gt 90 R
Java
Multithreading
concurrency
javautilconcurrent
为什么jdk中没有ConcurrentLinkedHashMap类?
这个问题直接接着问从我之前的问题来看 https stackoverflow com q 12299731 1527084 我想我的第二个问题的答案是否定的 所以我想了解为什么 java util concurrent 包中没有 Concu
Java
datastructures
javautilconcurrent
你能用 Future.cancel(true) 中断 BufferedReader.readLine() 吗?
假设我启动了一个线程 并且有这样的内容 initiate all the socket connection future executor submit new Runnable public void run while str in
Java
Multithreading
javautilconcurrent
ReentrantReadWriteLock 中的读锁和写锁是否有某种关联?
请详细解释一下合同 我不知道里面是否包含两把锁ReentrantReadWriteLock有某种关系吗 或者这些只是两把普通锁的捆绑 它允许多个线程同时读取资源 但要求线程等待独占锁才能写入资源 规则是 多个读者可以同时共享资源 如果你有一
Java
javautilconcurrent
reentrantreadwritelock
Hystrix 命令失败并显示“超时并且没有可用的后备”
我注意到我的应用程序中的某些命令失败了 Caused by com netflix hystrix exception HystrixRuntimeException GetAPICommand timed out and no fallb
Java
javautilconcurrent
Hystrix
重新初始化 ScheduledExecutorService 中的修复延迟
根据我的要求 我必须在一段时间后执行一些特定的代码 我选择做同样的事ScheduledExecutorService scheduleWithFixedDelay runnable 0 5 TimeUnit SECONDS 它对我来说工作得
Java
javautilconcurrent
Java 中的目录扫描器
连续扫描一组目录以查找一组文件名过滤器 对于到达的每个文件名过滤器 处理该文件并对所有文件重复这些步骤 jdk 1 5 中推荐的设计是什么 可能使用 java concurrent Executor 和 Future 我已经用网络爬虫完成了
Java
Multithreading
polling
javautilconcurrent
Java 从 ConcurrentHashMap 中删除特定项
使用remove 方法可以吗 我读过一篇文章 说remove方法中还没有添加同步功能 如何正确删除specificConcurrentHashMap 中的项目 示例代码 ConcurrentHashMap
Java
threadsafety
javautilconcurrent
ConcurrentHashMap
同步集合包装器工厂方法如何“拥有”传递给它的对象?
Brian Goetz 在 Java Concurrency in Practice 一书中说 传递给类的构造函数和方法的对象是不拥有由类本身 是因为他们是从外面来的 班级无法控制他们吗 他接着说 如果方法被明确设计为转移传入对象的所有权
Java
Multithreading
Collections
concurrency
javautilconcurrent
为什么Java中没有AtomicBoolean数组数据类型?
我注意到有NOJava 中的 AtomicBooleanArray 数据类型类似于 AtomicIntegerArray 虽然我可以使用 AtomicBoolean 来满足当前的需求 但我很想了解为什么 AtomicBooleanArray
Java
javautilconcurrent
对 CountedCompleter 的文档和来源感到困惑
这是一个代码片段java util concurrent CountedCompleter类 JDK 1 8 0 25 If the pending count is nonzero decrements the count otherwi
Java
concurrency
javautilconcurrent
forkjoinpool
类之间的 Java 共享条件抛出 IllegalMonitorStateException: null
我有这样的结构 锁包装器 用于存储锁 条件和响应中的对象 public class LockWrapper private Lock lock private Condition myCondition private MyObject m
Java
Multithreading
concurrency
locking
javautilconcurrent
更新 ConcurrentHashMap 中其他键的后果#computeIfAbsent
Javadoc 来自ConcurrentHashMap computeIfAbsent says 计算应该简短且简单 并且不得试图 更新此地图的任何其他映射 但是 据我所知 使用remove and clear 里面的方法mappingFu
Java
javautilconcurrent
ConcurrentHashMap
ConcurrentHashMap 有什么缺点吗?
我需要一个可从多个线程访问的 HashMap 有两个简单的选项 使用普通的 HashMap 并在其上同步 或者使用 ConcurrentHashMap 由于 ConcurrentHashMap 不会阻止读取操作 因此它似乎更适合我的需求 几
Java
Multithreading
HashMap
ConcurrentHashMap
javautilconcurrent
1
2
3
»