java - 在for循环里使用多线程查询数据库

Answer 1

Malah, jika anda ingin menggunakan kaedah ini kerana setiap tugasan pertanyaan agak perlahan, adalah lebih baik untuk mengoptimumkan SQL. Atau anda boleh menggunakan kaedah kumpulan benang berikut untuk mengendalikannya, tetapi kerumitan kod akan meningkat dengan banyak.
Jenis data berpakej yang dikembalikan oleh Futrue sepadan dengan jenis yang dikembalikan oleh sql anda
atau anda boleh menggunakan fork/join untuk memproses

public class CallableAndFuture {
    
    public static void main(String[] args) {
        ExecutorService threadPool = Executors.newSingleThreadExecutor();
        List<Future<Integer>> futures = new ArrayList<>();
        for (int i = 10; i < 15; i++) {
            futures.add(threadPool.submit(new Task(i)));
        }
        try {
            Thread.sleep(1000);// 可能做一些事情

            int allSum = 0;
            for (Future<Integer> f : futures) {
                int fsum = f.get();
                System.out.println("sum:" + fsum);
                allSum += fsum;
            }
            System.out.println("allSum:" + allSum);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        threadPool.shutdown();
    }
}


class Task implements Callable<Integer> {
    private int i;

    public Task(int i) {
        this.i = i;
    }

    @Override
    public Integer call() throws Exception {
        // 替换成db的查询
        int sum = 0;
        for (int j = 0; j <= i; j++) {
            sum += j;
        }
        return sum;
    }

}