java - java多线程回调

Question

我正在尝试对导入作业进行多线程处理，但遇到了导致重复数据的问题。我需要将我的 map 保留在循环之外，以便我的所有线程都可以更新并从中读取，但如果它不是最终的，我就无法执行此操作，并且如果它是最终的，我无法更新 map 。目前，我需要将 Map 对象放入 run 方法中，但是当值最初不在数据库中并且每个线程创建一个新值时，就会出现问题。这会导致数据库中出现重复数据。有人知道如何进行某种回调以更新我的外部 map 吗？

ExecutorService executorService = Executors.newFixedThreadPool(10);

final Map<Integer, Object> map = new HashMap<>();
map.putAll(populate from database);
for (int i = 0; i < 10; i++) {

    executorService.execute(new Runnable() {
        public void run() {

        while ((line = br.readLine()) != null) {
            if(map.containsKey(123)) {
                //read map object
                session.update(object);                
            } else {
                map.put(123,someObject);
                session.save(object);
            }            

            if(rowCount % 250 == 0)
            tx.commit;
        });

}

executorService.shutdown();

Answer 1

您需要使用一些同步技术。

有问题的部分是当不同的线程尝试将一些数据放入映射中时。

示例:

线程 1 正在检查映射中是否存在键为 123 的对象。在线程 1 将新对象添加到映射之前，线程 2 被执行。线程 2 还检查是否存在键为 123 的对象。然后两个线程都将对象 123 添加到映射。这会导致重复...

您可以在此处阅读有关同步的更多信息

http://docs.oracle.com/javase/tutorial/essential/concurrency/sync.html