Semaphore semaphore = new Semaphore(nThread);//定义几个许可
//这里
    ExecutorService executorService =new ThreadPoolExecutor(1, nThread,
            1000L, TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue<>(1));//创建一个固定的线程池
    for (T obj : list) {
        try {
            semaphore.acquire();
            executorService.execute(() -> {
                try {
                    func.accept(obj);
                } catch (Exception ex) {
                    Logger.error("startWithMultiThread 出错！"+ex.getMessage());
                } finally {
                    semaphore.release();
                }
            });
        } catch (InterruptedException e) {
            Logger.error("startWithMultiThread 出错！"+e.getMessage());
        }
    }
    

public static void main(String[] args) {
    ArrayList<Object> objects = Lists.newArrayList();
    for (int i = 0; i < 1000; i++) {
        objects.add(i);
    }
    startWithMultiThread(objects,5, obj -> {
        Threads.sleep(1000);
        System.out.println(obj);
    });
}