中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

怎么用java多線程統計數據

小億
99
2023-12-14 20:10:48
欄目: 編程語言

使用多線程可以加快數據統計的速度,以下是一種使用Java多線程進行數據統計的示例:

import java.util.ArrayList;
import java.util.List;
import java.util.Random;

public class DataStatistics {

    public static void main(String[] args) {
        int[] data = generateData(1000000); // 生成100萬個隨機數作為數據

        int threadCount = 4; // 設置線程數量
        List<Worker> workers = new ArrayList<>();

        // 創建并啟動多個Worker線程
        for (int i = 0; i < threadCount; i++) {
            Worker worker = new Worker(data, i * (data.length / threadCount), (i + 1) * (data.length / threadCount));
            workers.add(worker);
            worker.start();
        }

        // 等待所有Worker線程執行完畢
        for (Worker worker : workers) {
            try {
                worker.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        // 統計每個Worker線程的結果并求和
        int totalCount = 0;
        for (Worker worker : workers) {
            totalCount += worker.getResult();
        }

        System.out.println("數據總和為:" + totalCount);
    }

    // 隨機生成指定數量的數據
    private static int[] generateData(int count) {
        int[] data = new int[count];
        Random random = new Random();
        for (int i = 0; i < count; i++) {
            data[i] = random.nextInt(100);
        }
        return data;
    }

    // Worker線程用于統計數據的子任務
    private static class Worker extends Thread {
        private int[] data;
        private int start;
        private int end;
        private int result;

        public Worker(int[] data, int start, int end) {
            this.data = data;
            this.start = start;
            this.end = end;
        }

        public int getResult() {
            return result;
        }

        @Override
        public void run() {
            for (int i = start; i < end; i++) {
                result += data[i];
            }
        }
    }
}

在上述示例中,首先生成了100萬個隨機數作為數據。然后,根據指定的線程數量創建了多個Worker線程,每個Worker線程負責統計數據的一部分。每個Worker線程在run()方法中進行計算,并將結果保存在result變量中。最后,主線程等待所有Worker線程執行完畢后,將每個Worker線程的結果相加得到最終的統計結果。

0
乌鲁木齐县| 东平县| 同心县| 东港市| 南投市| 清苑县| 布尔津县| 宣威市| 陇川县| 瑞丽市| 聂荣县| 望城县| 修武县| 亳州市| 沙雅县| 大冶市| 台中市| 丹阳市| 洱源县| 津南区| 靖安县| 浦北县| 南开区| 长丰县| 山东省| 吉安县| 石首市| 南汇区| 台州市| 五常市| 古交市| 孝义市| 长治县| 合阳县| 团风县| 上犹县| 岢岚县| 和田市| 正阳县| 元氏县| 咸宁市|