JAVA多線程並發任務執行

  想在網上找個多線程任務並發的代碼，沒找到，我自己寫了個。

 功能：提交一個匿名函數和數據列表，開啟多線程執行此函數處理數據。

核心調用函數
runTask(Consumer task, Consumer finaltask, List datas, int maxThreads) 

task 任務函數

finaltask 全部線程結束后執行的函數

datas task.accept 要用到的處理數據列表，成員是 HashMap，必須要有id屬性。

maxThreads  指定並發線程數量

package fsrm.tools;

import java.util.*;
import java.util.function.Consumer;

public class ParallelTask {

    private static int listcount = 0;
    private static Vector datas = new Vector();

    public class RunThread extends Thread {
        Consumer task, fianltask;

        public RunThread(String name, Consumer task, Consumer ftask) {
            super(name);
            this.task = task;
            this.fianltask = ftask;
        }

        @Override
        public void interrupt() {
            super.interrupt();
            synchronized (this) {
                listcount--;
                if (listcount == 0) {
                    // 我是最后一個了，那么，好吧
                    fianltask.accept(null);
                }
            }
        }

        @Override
        public void run() {
            while (!datas.isEmpty()) {
                HashMap<String, Object> data = (HashMap) datas.remove(0);
                System.out.println("線程" + getName() + " 開始處理新數據 " + data.get("id"));
                if (task != null) task.accept(data);
                System.out.println("線程" + getName() + " 處理數據完成 " + data.get("id"));
            }
            synchronized (this) {
                listcount--;
                if (listcount == 0) {
                    // 我是最后一個了，那么，好吧
                    fianltask.accept(null);
                }
            }
        }
    }

    void runTask(Consumer task, Consumer finaltask, List datas, int maxThreads) {
        ParallelTask.listcount = maxThreads;
        this.datas.addAll(datas);
        for (int i = 0; i < maxThreads; i++) {
            new RunThread(String.valueOf(i), task, finaltask).start();
        }
    }

    public static void main(String[] args) throws Exception {
        ParallelTask pt = new ParallelTask();

        ArrayList<Object> datas = new ArrayList();
        for (int i = 1; i < 33; i++) {
            HashMap<String, Object> d = new HashMap<>();
            d.put("id", "task_" + i);
            d.put("data", i * 3);
            datas.add(d);
        }

        pt.runTask(o -> {
            try {
                System.out.println("do...... " + ((HashMap) o).get("data"));
                Thread.sleep(Math.round(Math.random() * 60 + 5) * 100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, o -> {
            System.out.println("全部工作完成了，歡迎下次再來！！！");
        }, datas, 10);
    }
}