java中的线程处理

Question

我正在尝试为我的项目设计一个高效的线程组件。我的 Java 代码正在使用线程（线程池）读取 1000 个提要文件。每个文件有 1000 行，行可以在多个文件中重复。有可能一半的信息在一个文件中，另一半在另一个文件中（但我们有自己的业务逻辑要关联）。我们正在读取这些文件并插入到数据库中。目前，我们一个一个地插入（使用锁插入数据库只是为了确保所有文件的每条记录只有一行）但我想设计这样的锁应该在记录属性上完成说，emp数据应该是连续的和公司数据一起顺序但emp和公司数据应该并行。另一个我们不知道记录类型的问题，它是动态的。明天我可能会得到工资数据。

Answer 1

我认为您希望并行操作一堆数据，并在它们运行时使用不同的操作锁定共享锁。

下面是一个例子：在一张地图中存储多个锁，您可以使用从您的数据（例如员工数据或公司数据）中绘制的一些映射来查找该地图。

import java.util.Collection;
import java.util.HashSet;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class MultipleLocks {

    static Map<Operation.Type, Lock> locks = new ConcurrentHashMap<>();

    public static void main(String... args) {
        Collection<Operation> operations = new HashSet<>();
        operations.add(new Operation(Operation.Type.ALPHA, () -> System.out.println(1)));
        operations.add(new Operation(Operation.Type.ALPHA, () -> System.out.println(2)));
        operations.add(new Operation(Operation.Type.ALPHA, () -> System.out.println(3)));
        operations.add(new Operation(Operation.Type.BRAVO, () -> System.out.println(4)));
        operations.add(new Operation(Operation.Type.BRAVO, () -> System.out.println(5)));
        operations.add(new Operation(Operation.Type.CHARLIE, () -> System.out.println(5)));

        operations.parallelStream().forEach(operation -> {
            Lock lock = locks.computeIfAbsent(operation.type, type -> new ReentrantLock());
            lock.lock();
            operation.op.run();
            lock.unlock();
        });
    }

    static class Operation {
        enum Type {
            ALPHA, BRAVO, CHARLIE;
        }

        Type type;
        Runnable op;

        Operation(Type alpha, Runnable op) {
            type = alpha;
            this.op = op;
        }
    }
}