java多线程

package com.friend.demo;

import com.wondersgroup.wdls.data.commons.DBUtils;
import com.wondersgroup.wdls.dbinit.DataSourceConfig;
import org.junit.jupiter.api.Test;

import java.util.Collection;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Testduoxianc {

    private Integer threadCount=10;

    private ExecutorService threadPool;


    @Test
    public void execute() {
        DataSourceConfig.init();
        threadPool = Executors.newFixedThreadPool(threadCount);
       // String db = ConfigHolder.get("db.connection.url");
        // 锁成功
        try {
            Collection<Callable<Object>> resultb = new LinkedList<>();
            List<String> aaa027s=DBUtils.query("select pid from t_testdxc where zt='0' limit 0,10000",String.class);
            for (String aaa027 : aaa027s){
                //int a = 0;
                //while (a<10){
                    resultb.add(new task1(aaa027));
                 //   a++;
                }
            }

            threadPool.invokeAll(resultb);
        } catch (InterruptedException e1) {

            Thread.currentThread().interrupt();
        }

    }

    private class task1 implements Callable<Object> {
        private String yjjhDTO;
        public task1 (String yjjhDTO){
            this.yjjhDTO = yjjhDTO;
        }
        public Object call() throws Exception {
            try {
                DBUtils.execSql("update t_testdxc set zt='1' where pid=?",yjjhDTO);
            }catch (Exception e){
            }

            return null;
        }
    }

}