抚州市临川区建设局网站,app制作平台灼灼琉璃夏漫画,旺道seo推广,聚美联盟网站怎么做标题java四种线程池及使用示例
1、线程工厂
1、我们先来写ThreadFactory#xff0c;在创建线程池时候可以传入自定义的线程工厂#xff0c;线程工厂说白了就是用来定制线程的一些属性#xff1a;名字、优先级、是否为守护线程。直接看代码即可。
当然创建线程池的时候可以…标题java四种线程池及使用示例
1、线程工厂
1、我们先来写ThreadFactory在创建线程池时候可以传入自定义的线程工厂线程工厂说白了就是用来定制线程的一些属性名字、优先级、是否为守护线程。直接看代码即可。
当然创建线程池的时候可以不传入自定义线程工厂。
public class MyThreadFactory implements ThreadFactory {private static final String thread_prefix self_thread;private AtomicInteger integer new AtomicInteger(0);private String threadName null;public MyThreadFactory(String threadName) {this.threadName threadName;}public MyThreadFactory() {}Overridepublic Thread newThread(Runnable r) {Thread thread new Thread(r);String name threadName null ? thread_prefix integer.getAndIncrement() : threadName integer.getAndIncrement();thread.setName(name);return thread;}
}2、我们来详细看一下四种线程池
单一线程的线程池可缓存的线程池可周期性执行的线程池固定数目的线程池.newSingleThreadExecutor.newCachedThreadPool.newScheduledThreadPool.newFixedThreadPool
1、单一线程的线程池
此线程池只有一个线程用仅有的一个线程来执行任务保证所有的任务按照指定顺序FIFOLIFO优先级执行所有的任务都保存在队列LinkedBlockingQueue中等待唯一的单线程来执行任务。 private static final Object lock new Object();private static int count 0;private static void testSingleThreadThreadPool() {ExecutorService service Executors.newSingleThreadExecutor(new MyThreadFactory(singleThread));for (int i 0; i 6; i) {test(service);}}private static void test(ExecutorService service) {synchronized (lock) {count;System.out.println(Thread.currentThread().getName());if (count 5) {System.out.println(count 5 shutdown );service.shutdown();}}}可以从输出看到只new了一个线程。
2、可缓存的线程池
创建一个可缓存的无界线程池如果线程池长度超过处理需要可灵活回收空线程若无可回收则新建线程。当线程池中的线程空闲时间超过60s则会自动回收该线程当任务超过线程池的线程数则创建新的线程线程池的大小上限为Integer.MAX_VALUE,可看作无限大。 private static void testCachedThreadPool() {ExecutorService service Executors.newCachedThreadPool(new MyThreadFactory(cached));for (int i 0; i 1000; i) { // 循环数稍微大一点 模拟线程回收后被复用service.submit(new Runnable() {Overridepublic void run() {System.out.println(Thread.currentThread().getName()); // 可从控制台看出相同线程名的线程}});}}3、可周期性执行的线程池 private static void testScheduleThreadPool() {/*** 可周期性执行的线程池 延迟2秒执行 每间隔4秒执行一次** 是“以固定的频率”执行period周期指的是两次成功执行之间的时间。* 上一个任务开始的时间计时一个period后检测上一个任务是否执行完毕* 如果上一个任务执行完毕则当前任务立即执行如果上一个任务没有执行完毕* 则需要等上一个任务执行完毕后立即执行。*/ExecutorService service Executors.newScheduledThreadPool(6, new MyThreadFactory());((ScheduledExecutorService) service).scheduleAtFixedRate(new Runnable() {Overridepublic void run() {test(service);}}, 2, 4, TimeUnit.SECONDS);// 定时 执行一次 的任务延迟1s后执行((ScheduledExecutorService) service).schedule(new Runnable() {Overridepublic void run() {System.out.println(Thread.currentThread().getName() , delay 1s);}}, 1, TimeUnit.SECONDS);/*** “以固定的延时”执行delay延时指的是一次执行终止和下一次执行开始之间的延迟。*/((ScheduledExecutorService) service).scheduleWithFixedDelay(new Runnable() {Overridepublic void run() {long start new Date().getTime();System.out.println(scheduleWithFixedDelay 开始执行时间: DateFormat.getTimeInstance().format(new Date()));try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}long end new Date().getTime();System.out.println(scheduleWithFixedDelay执行花费时间 (end - start) / 1000 m);System.out.println(scheduleWithFixedDelay执行完成时间 DateFormat.getTimeInstance().format(new Date()));System.out.println();System.out.println();}}, 2, 3, TimeUnit.SECONDS);}4、固定数目的线程池
这个就很好理解了。固定数量的线程。 /*** 固定数量的线程池*/private static void testFixedThreadPool() {ExecutorService service Executors.newFixedThreadPool(5, new MyThreadFactory());for (int i 0; i 8; i) {service.submit(new Runnable() {Overridepublic void run() {test(service);}});}}5、方法对比
