用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字
云代码 - java代码库

线程池

2022-07-01 作者: 一一举报

[java]代码库

package com.dcrj.thread;

import java.util.concurrent.*;

public class ThreadFourDemo {
    public static void main(String[] args) {
        //使用线程池的工厂方法类创建线程池
        //fixedThreadPool();
        //scheduledThreadPool();
        threadExecutorPool();
    }

    public static void fixedThreadPool() {
        ThreadFour threadFour = new ThreadFour();
        //手动创建固定线程数的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(3);
        //submit提交任务并执行,带回返回值的任务
        //execute执行任务不要返回值
        //执行的是任务个数
        for (int i = 0; i < 10; i++) {
            executorService.execute(threadFour);
        }
    }

    public static void scheduledThreadPool() {
        ThreadFour threadFour = new ThreadFour();
        //手动创建固定线程数的线程池
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(5);
        //submit提交任务并执行,带回返回值的任务
        //execute执行任务不要返回值
        //执行的是任务个数
        for (int i = 0; i < 7; i++) {
            executorService.schedule(threadFour, 2, TimeUnit.SECONDS);
        }
        executorService.shutdown();
    }

    /***
     * 最终线程池的使用
     * */
    public static void threadExecutorPool() {
        ThreadFour threadFour = new ThreadFour();
        ThreadPoolExecutor threadPoolExecutor1 = new ThreadPoolExecutor(2,
                5,
                2,
                TimeUnit.HOURS,
                new ArrayBlockingQueue<Runnable>(5));

        for (int i = 0; i < 10; i++) {
            threadPoolExecutor1.execute(threadFour);
        }
    }

}


网友评论    (发表评论)


发表评论:

评论须知:

  • 1、评论每次加2分,每天上限为30;
  • 2、请文明用语,共同创建干净的技术交流环境;
  • 3、若被发现提交非法信息,评论将会被删除,并且给予扣分处理,严重者给予封号处理;
  • 4、请勿发布广告信息或其他无关评论,否则将会删除评论并扣分,严重者给予封号处理。


扫码下载

加载中,请稍后...

输入口令后可复制整站源码

加载中,请稍后...