用Java构建高效的多线程数组

我有许多线程将类似结果的对象添加到数组中,并希望通过删除同步来提高此区域的性能.

为此,我希望每个线程将其结果发布到ThreadLocal数组 – 然后一旦处理完成,我就可以将这些数组合并到以下阶段.不幸的是,为此目的,ThreadLocal有一个明显的问题:我无法在最后组合集合,因为没有线程可以访问另一个集合.

我可以通过在创建ThreadLocal时将每个ThreadLocal数组添加到其旁边的列表来解决这个问题,所以我以后可以使用所有列表(这将需要同步,但每个线程只需要发生一次),但是为了避免内存泄漏我将不得不以某种方式让所有线程在最后返回以清理他们的ThreadLocal缓存…我更宁愿添加结果的简单过程是透明的,而不需要任何后续工作除了简单地添加结果.

是否有编程模式或现有类似ThreadLocal的对象可以解决此问题?

最佳答案 你说得对,ThreadLocal对象只能被当前线程访问.如果要跨线程进行通信,则无法使用ThreadLocal,而应使用线程安全的数据结构,例如
ConcurrentHashMap
ConcurrentLinkedQueue.

对于您正在描述的用例,在线程之间共享ConcurrentLinkedQueue并让它们根据需要写入队列是很容易的.一旦完成它们(Thread.join()将等待它们完成),您可以将队列读入您需要的任何其他数据结构.

点赞