189 8069 5689
Ta是一种标准的资源池模式
将资源的创建和销毁都委托给资源池完成 用户只需要关注取得资源之后自己的核心操作
提前预留活跃资源 在用户需要的时候 能够第一时间满足用户对资源的需求 从而让用户感受很好
假如一个线程的完整执行时间 T 则T由三部分时间构成
T = t1 + t2 + t3
t1 : 在操作系统当中创建一个线程所消耗的时间
t2 : 执行线程核心逻辑的时间 = run()
t3 : 在操作系统当中销毁一个线程所消耗的时间
如果run()当中的操作非常简练 则t2所占T的比例就会很小
此时创建和销毁所带来的时间开销就会很大 为什么不引入可重用的资源池~
newCachedThreadPool 创建一个可缓存的线程池，如果线程池长度超过处理需求，可灵活回收空闲线程，若无可回收，则新建线程
newFixedThreadPool 创建一个定长线程池，可控制线程大并发数，超出的线程会在队列中等待
newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行
newSingleThreadExecutor 创建一个单线程化的线程池，它只会唯一的工作线程来执行任务
import java.util.concurrent.*;//JUC
import java.util.*;
public class TestThreadPool{public static void main(String[] args)throws Exception{//白话版：端茶倒水的服务员 es = 职业介绍所.新建端茶倒水的服务员手持3杯水~
//学术版：执行器服务的对象 es = 执行器的工具类.新建一个修复后可以重用的线程池 当中预留3个活跃线程
ExecutorService es = Executors.newFixedThreadPool(2);//固定个数的全职服务员
//Executors.newCachedThreadPool(); //60S 一分钟 不固定个数的兼职服务员
//Executors.newSingleThreadExecutor();//形成程序当中的"独木桥"~
ThreadOne t1 = new ThreadOne();//新生
//白话版：找服务员要水喝 而不要自己去接水
//学术版：将线程任务t1 提交给执行器服务
es.submit(t1);
ThreadTwo t2 = new ThreadTwo();
es.submit(t2);
ThreadThree t3 = new ThreadThree();
Futuref = es.submit(t3);
//我们可以根据自己的需求是否需要未来当中的数据来决定是否调用get()
System.out.println("这里是不需要返回值的操作 例如喝杯水 讲讲课 顺道等着勋勋回来~");
//get()之前是可以利用t3还在执行的时候去做其它处理的~
String returnValue = f.get();//阻塞之后的操作 等待未来来到 等待勋勋买烟回来
System.out.println(returnValue + " 抽烟的操作 必须在买烟返回之后~");
//关闭执行器服务 = 让服务员下班
Listbthld = es.shutdownNow();//es.shutdown();
}
}
class ThreadThree implements Callable{@Override
public String call()throws Exception{for(int i = 0;i<200;i++){ System.out.println("我是创建线程的第三种方式 3rd way ");
}
return "ETOAK VIVA";
}
}
class ThreadTwo implements Runnable{@Override
public void run(){for(int i = 0;i<200;i++){ System.out.println("我是创建线程的第二种方式 2nd way ");
}
}
}
class ThreadOne extends Thread{@Override
public void run(){for(int i = 0;i<200;i++){ System.out.println("我是创建线程的第一种方式 1st way ");
}
}
}
shutdown() : 不再接受新任务的提交 但是已经提交的所有任务都要执行完
shutdownNow() : 不再接受新任务的提交 已经开始执行的能够执行完
但是还没开始执行的 将直接退回给我们~
它弥补了原本Runnable接口当中run()的两大不足
run()被定义为void方法 执行结束之后 线程无法返回数据
run()没有任何throws声明 所以 逼迫程序员 线程体当中try catch
如果将Callable接口的返回值对象设计为String那么调用Callable接口实现的线程的时必须等待Callable接口的Call()执行结束
使用Future对象的话我们只有调用Future对象的get()方法才会阻塞
我们可以根据自己的需求是否需要未来当中的数据来决定是否调用get()
你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧