多线程

  • 一、线程
    • 1.普通方法调用和多线程
    • 2.程序、进行、线程
  • 二、线程创建
    • 1.继承Thread类
    • 2.实现Runable接口
    • 3.实现Callable接口
    • 4.静态代理模式
    • 5、Lamda表达式
  • 三、线程状态
    • 1.线程状态
    • 2.线程方法
    • 3.线程停止
    • 4.线程休眠sleep
    • 5.线程礼让
    • 5.join
    • 6.线程状态观测
    • 7.线程优先级
    • 8.守护(daemon)线程
  • 四、线程同步
    • 1.并发与并行
    • 2.线程同步——等待机制
      • 2.1 队列 和 锁
      • 2.2 线程同步
      • 2.3 同步方法
      • 2.4 同步块
    • 3.死锁
    • 4. Lock锁
      • 4.1 lock(锁)
      • 4.2 synchronized 与 Lock 的对比
  • 五、线程协作——生产者消费者模式
    • 1.线程通信
    • 2.问题分析
    • 3.线程通信方法
    • 4.解决方法一
    • 5.解决方法二
    • 6.使用线程池

一、线程

1.普通方法调用和多线程


可以看出,普通方法调用一个run()方法,它会等这个方法执行完,再继续主线程的任务,有一个等待的过程,只有一个执行路径。
而多线程呢,是多条执行路径,主线程和子线程并行交替执行。

2.程序、进行、线程

在操作系统中,运行的程序就是进程,一个进程里可以有多个线程。比如,此刻你电脑上的游戏程序开始运行,变成一个进程,里面即有画面又有声音,这一个个属于线程。

程序——指令和数据的有序集合,是一个静态的概念
进程——程序的一个执行过程,是一个动态的概念,也是系统资源分配的单位,我们说,给某个进程给多少资源等等的。
线程——一个进程中包含若干个线程,至少有一个,真正执行的其实是线程线程是CPU调度和执行的单位

  • 核心点——注意

1.线程是独立执行的路径,因为CPU同一时间只做一件事
2.在程序运行时,即使没有自己创建线程,后台也会有多个线程,如主线程,gc线程
3.main() 称之为主线程,为系统的入口,用于执行整个程序
4.在一个进程中,如果开辟了多个线程,线程的运行由调度器(CPU)安排调度,调度器是与操作系统紧密相关的,先后顺序是不能人为的干预的
5.对同一份资源操作时,会存在资源抢夺的问题,需要加入并发控制
6.线程会带来额外的开销,如cpu调度时间,并发控制开销
7.每个线程在自己的工作内存交互,内存控制不当会造成数据不一致

二、线程创建

1.继承Thread类

  • 自定义线程类继承Thread类
  • 重写run()方法,编写线程体
  • 创建线程对象,调用start()方法启动线程
public class TestThread extends Thread {public static void main(String[] args) {TestThread thread = new TestThread();thread.start();System.out.println("main");}@Overridepublic void run() {//线程体for (int i = 0; i < 8; i++) {System.out.println("线程执行了");}}
}
  • 注意:线程不一定立即执行,看CPU调度

2.实现Runable接口

  • 定义一个类实现runable接口
  • 重写run()方法
  • 创建线程对象,调用start方法启动线程
public class TestRunnable implements Runnable {@Overridepublic void run() {System.out.println("runnable线程");}public static void main(String[] args) {TestRunnable runnable = new TestRunnable();//创建代理类对象Thread thread = new Thread(runable);thread.start();System.out.println("main线程");}
}
  • 实现runable接口这种方法避免了单继承的局限性,灵活方便,可以同一个对象被多个线程使用。
Threadmy thread = new Threadmy();
new Thread(thread,"1").start();
new Thread(thread,"2").start();
new Thread(thread,"3").start();

3.实现Callable接口

  • 实现callable接口,需要返回值类型
  • 重写call方法,需要抛出异常
  • 创建目标对象
  • 创建执行服务:ExecutorService ser = Executors.newFixedThreadPool(1);
  • 提交执行Future<Boolean> result1 = ser.submit(t1);
  • 获取结果boolean r1 = result1.get()
  • 关闭服务 ser.shutdownNow();
public class TestCallable implements Callable {@Overridepublic Object call() throws Exception {System.out.println("callable");return true;}public static void main(String[] args) throws ExecutionException, InterruptedException {//创建对象TestCallable callable = new TestCallable();//创建执行服务ExecutorService service = Executors.newFixedThreadPool(1);//提交执行Future<Boolean> result = service.submit(callable);//获取结果Boolean re = result.get();//关闭service.shutdownNow();System.out.println(re);//FutureTask<Integer> future = new FutureTask<Integer>(new TestCallable());//new Thread(future).start();//Integer integer = future.get();//System.out.println(integer);}
}

4.静态代理模式

静态代理模式——目标对象和真实对象去实现同一个接口,代理对象要代理真实角色(需要有真实参数的传输)
好处——代理对象可以做真实对象做不了的事,真实对象专注做自己的事

  • 实现静态模式三要素

1、真实角色(委托对象)
2、代理角色
3、共同实现的接口

  • 对比以实现Runable接口的形式创建多线程,可以发现,代理角色Thread类不需要我们创建,我们只需要写委托对象,实现Runnable接口,把委托对象的引用传递给Thread,借助Thread对象来开启线程即可。
  • 我们发现thread底层其实是实现了Runnable接口,而runable也实现了这个接口,这就是它们共同实现的接口,thread作为代理,runable作为委托人。
class Thread implements Runnable {/* Make sure registerNatives is the first thing <clinit> does. */private static native void registerNatives();static {registerNatives();}

5、Lamda表达式

public class lambda3 {public static void main(String[] args) {//在对接口的引用时,采用的是实例化实现该接口的类ILove love = new Love();love.lambda(0);//匿名内部类love = new ILove() {@Overridepublic void lambda(int a) {System.out.println(a);}};love.lambda(2);//lambda表达式love = (int a)->{System.out.println(a);};love.lambda(3);//简化1: 去掉括号love = a -> {System.out.println("a");};love.lambda(4);//简化2:去掉花括号love = a -> System.out.println("a");love.lambda(5);}
}
interface ILove{void lambda(int a);
}
class Love implements ILove{@Overridepublic void lambda(int a) {System.out.println("a");}
}
  • lambda表达式前提:
    必须是函数式接口.

  • 函数式接口

任何接口,如果只包含唯一一个抽象方法,那么它就是函数式接口。

public interface Runnable { public abstract void run(); }

三、线程状态

1.线程状态

  • new创建状态
    Thread t = new Thread() 线程对象一旦创建就进入到 了新生状态

  • 就绪状态
    当调用start()方法,线程立即进入就绪状态,但不意味着立即调度执行

  • 运行状态
    得到CPU的调度,进入运行状态,线程才真正执行线程体的代码块

  • 阻塞状态
    当调用sleep(),wait或同步锁定时,线程进入阻塞状态,就是代码不往下执行了,阻塞事件解除后,重新进入就绪状态,等待CPU调度。

  • dead死亡状态
    线程中断或者结束,一旦进入死亡状态,就不能再次启动

2.线程方法

3.线程停止

  • 不推荐使用JDK提供的stop()、destroy()方法,已废弃
  • 推荐线程自己停下来
  • 利用标志位让线程停下来
public class Stop implements Runnable{//1、线程中定义线程体使用的标识private boolean flag = true;@Overridepublic void run() {int i = 0;//2.线程体使用该标识while (flag) {System.out.println("子线程执行" + i++);}}//3.对外提供方法改变标识public void stop(){this.flag = false;}public static void main(String[] args) {Stop stop = new Stop();new Thread(stop).start();for (int i = 0; i < 100; i++){System.out.println("主线程"+i);if (i == 67){stop.stop();System.out.println("停止了");}}}
}

4.线程休眠sleep

1、sleep(时间)指定当前线程阻塞的毫秒数
2、sleep存在异常InterruptedException
3、sleep时间达到后线程进入就绪状态
4、sleep可以模拟网络延时,倒计时等
5、每一个对象都有一个锁,sleep不会释放锁

public class TestSleep2 {public static void main(String[] args) throws InterruptedException {TestSleep2 testSleep2 = new TestSleep2();//获取系统时间Date startTime = new Date(System.currentTimeMillis());while (true) {System.out.println(new SimpleDateFormat("HH:mm:ss").format(startTime));Thread.sleep(1000);startTime = new Date(System.currentTimeMillis());}}//倒计时方法private void tenDown() throws InterruptedException {int num = 10;for (int i = 10; i > 0; i--) {Thread.sleep(1000);System.out.println("倒计时:"+i);}}
}

5.线程礼让

1、礼让线程,让当前正在执行的线程暂停,但不阻塞
2、将线程从运行状态转为就绪状态
3、让cpu重新调度,礼让不一定成功!看CPU心情

public class TestYield {public static void main(String[] args) throws InterruptedException {MyYield myYield = new MyYield();new Thread(myYield,"小明").start();new Thread(myYield,"老师").start();}
}class MyYield implements Runnable{@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+"-->启动了");Thread.yield();//礼让System.out.println(Thread.currentThread().getName()+"-->停止了");}
}

礼让成功输出

老师-->启动了
小明-->启动了
老师-->停止了
小明-->停止了

不成功则输出

小明-->启动了
小明-->停止了
老师-->启动了
老师-->停止了

5.join

join合并线程,待此线程执行完成后,再执行其他线程,其他线程阻塞
可以想象成插队

public class TestJoin implements Runnable{public static void main(String[] args) throws InterruptedException {TestJoin testJoin = new TestJoin();Thread thread = new Thread(testJoin);thread.start();for (int i = 0; i < 100; i++) {if (i==80){//强制执行thread.join();}System.out.println("我是主线程:"+i);}}@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println("我是要插队的线程:"+i);}}
}

此代码的结果应该是,80之前主线程和插队线程随即执行,看CPU调度,一旦i=80,主线程停止,插队线程一直执行完毕,然后主线程再接着。

6.线程状态观测

  • Thread.State

线程状态:
new:尚未启动,新生
running:在Java虚拟机中执行的线程
blocked:被阻塞等待
waiting:一个线程在等待另一个线程执行一个动作时在这个状态,比如join
timed_waiting:一个线程在一个特定的等待时间内等待另一个线程完成一个动作会在这个状态
terminated:死亡

7.线程优先级

线程的优先级用数字表示,范围从1~10. Thread.MIN_PRIORITY = 1; Thread.MAX_PRIORITY = 10; Thread.NORM_PRIORITY = 5;

  • 使用以下方式改变或获取优先级
 getPriority() setPriority(int xxx)
  • 优先级的设定建议在start()调度前
thread.setPriority(int 6);
thead.start();
  • 优先级低只是意味着获得调度的概率低.并不是优先级低就不会被调用了.这都是看CPU的调度

8.守护(daemon)线程

1、线程分为用户线程和守护线程
2、 虚拟机必须确保用户线程执行完毕,当存在任何一个用户线程未离开,JVM是不会离开的
3、虚拟机不用等待守护线程执行完毕如果只剩下守护线程未离开,JVM是可以离开的
如,后台记录操作日志,监控内存,垃圾回收等待

四、线程同步

多个线程操作同一个资源

1.并发与并行

  • 并发:同一个对象被多个线程同时操作
  • 并行:两个任务同时运行(需要多核CPU)

并发就是两个任务都请求执行,而处理器只接受一个任务,就把这两个任务安排轮流进行,由于时间间隔较短,使人感觉两个任务都在运行。

2.线程同步——等待机制

现实生活中,我们会遇到 ” 同一个资源 , 多个人都想使用 ” 的问题 , 比如,食堂排队打饭 , 每个人都想吃饭 , 最天然的解决办法就是 , 排队 . 一个个来。

处理多线程问题时 , 多个线程访问同一个对象 , 并且某些线程还想修改这个对象 . 这时候我们就需要线程同步。

  • 线程同步其实就是一种等待机制 , 多个需要同时访问此对象的线程进入这个对象的等待池形成队列, 等待前面线程使用完毕 , 下一个线程再使用。

2.1 队列 和 锁

2.2 线程同步

  • 由于同一个进程的多个线程共享同一块存储空间,虽然很方便,但是产生了冲突问题。为了保证数据在方法中被访问的正确性,我们在访问时加入锁机制synchronized,当一个线程获得对象的排他锁(写锁),独占资源,其他线程必须等待,使用后释放锁即可。
  • 存在的问题:
    1、一个线程持有锁会导致其他所有需要此锁的线程挂起
    2、在多线程竞争下 , 加锁 , 释放锁会导致比较多的上下文切换 和 调度延时,引起性能问题 ;
    3、如果一个优先级高的线程等待一个优先级低的线程释放锁,会导致优先级倒置 , 引起性能问题

2.3 同步方法

  • synchronized 关键字——synchronized 方法
public synchronized void method(int args) {}

synchronized方法控制对 “对象” 的访问 , 默认锁的是this,每个对象对应一把锁 , 每个 synchronized 方法都必须获得调用该方法的对象的锁才能执行 , 否则线程会阻塞 , 方法一旦执行 , 就独占该锁 , 直到该方法返回才释放锁 , 后面被阻塞的线程才能获得这个锁 , 继续执行。

  • 缺陷 : 若将一个大的方法申明为synchronized 将会影响效率
  • 弊端:方法里面需要修改的内容才需要锁, 锁的太多 , 浪费资源。

2.4 同步块

  • synchronized (Obj ) { }
  • 同步其他对象用同步块,同步方法是同步本对象this
  • Obj 称之为 同步监视器

Obj 可以是任何对象 , 但是推荐使用共享资源作为同步监视器
同步方法中无需指定同步监视器 , 因为同步方法的同步监视器就是this , 就是这个对象本身 , 或者是 class

  • 同步监视器的执行过程
  1. 第一个线程访问 , 锁定同步监视器 , 执行其中代码 .
  2. 第二个线程访问 , 发现同步监视器被锁定 , 无法访问 .
  3. 第一个线程访问完毕 , 解锁同步监视器 .
  4. 第二个线程访问, 发现同步监视器没有锁 , 然后锁定并访问

3.死锁

死锁就是我要你的,你要我的,我两僵住了。
多个线程各自占有一些共享资源 , 并且互相等待其他线程占有的资源才能运行 , 而导致两个或者多个线程都在等待对方释放资源 , 都停止执行的情形 。某一个同步块同时拥有 “ 两个以上对象的锁 ” 时 , 就可能会发生 “ 死锁 ” 的问题

//死锁问题
//两个线程抱着自己的锁 , 然后想要对方的锁 .
// 于是产生一个问题 ---> 死锁
public class DeadLocked {public static void main(String[] args) {Makeup g1 = new Makeup(0,"白雪公主");Makeup g2 = new Makeup(1,"灰姑凉");new Thread(g1).start();new Thread(g2).start();}
}
//化妆
class Makeup implements Runnable{//选择int choice;//谁进来了String girlName;//两个对象static LipStick lipStick = new LipStick();static Mirror mirror = new Mirror();public Makeup(int choice,String girlName){this.choice = choice;this.girlName = girlName;}@Overridepublic void run() {//化妆try {makeup();} catch (InterruptedException e) {e.printStackTrace();}}//化妆的方法public void makeup() throws InterruptedException {if (choice==0){ //先拿口红,再拿镜子synchronized (lipStick){System.out.println(this.girlName+"拿到口红");Thread.sleep(1000);//等待拿镜子的人释放锁synchronized (mirror){System.out.println(this.girlName+"拿到镜子");}}}else { //先拿镜子 , 再拿口红synchronized (mirror){System.out.println(this.girlName+"拿到镜子");Thread.sleep(2000);//等待拿口红的人释放锁synchronized (lipStick){System.out.println(this.girlName+"拿到口红");}}}}
}
}

可以发现上述代码中,下面这个代码中产生死锁,一个同步代码块中,同时拥有两个以上对象的锁。

synchronized (lipStick){System.out.println(this.girlName+"拿到口红");Thread.sleep(1000);//等待拿镜子的人释放锁synchronized (mirror){System.out.println(this.girlName+"拿到镜子");}
}

解决办法就是把里面的拿出来

synchronized (lipStick){System.out.println(this.girlName+"拿到口红");Thread.sleep(1000);}//等待拿镜子的人释放锁synchronized (mirror){System.out.println(this.girlName+"拿到镜子");}
  • 死锁的避免方法
    产生死锁的四个必要条件(死锁只有同时满足以下四个条件才会发生):
    1)互斥——一个资源每次只能被一个进程使用

    2)请求与保持条件——一个进程因请求资源而阻塞时,对已获得的资源保持不放

3)不剥夺条件——进程已获得的资源,在末使用完之前,不能强行剥夺

4)循环等待条件 ——若干进程之间形成一种头尾相接的循环等待资源关系

  • 避免死锁问题的发生
    死锁的四个必要条,我们只要想办法破其中的任意一个或多个条件 就可以避免死锁发生

4. Lock锁

  • java.util.concurrent.locks.Lock接口是控制多个线程对共享资源进行访问的工具。 锁提供了对共享资源的独占访问,每次只能有一个线程对Lock对象加锁,线程开始访问共享资源之前应先获得Lock对象。
  • ReentrantLock 类实现了 Lock ,它拥有与 synchronized 相同的并发性和内存语义,在实现线程安全的控制中,比较常用的是ReentrantLock,可以显式加锁、释放锁。

4.1 lock(锁)

class A{private final ReentrantLock lock = new ReenTrantLock(); public void m(){ lock.lock(); try{ //保证线程安全的代码; } finally{ lock.unlock(); //如果同步代码有异常,要将unlock()写入finally语句块 } }
}
public class TestLock {public static void main(String[] args) {HelloWorld helloWorld = new HelloWorld();new Thread(helloWorld).start();new Thread(helloWorld).start();}
}
class HelloWorld implements Runnable{int ticketNums = 100;//可重入锁private final ReentrantLock lock = new ReentrantLock();@Overridepublic void run() {while (true){try {lock.lock(); //加锁//判断是否有票if (ticketNums>0){try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(ticketNums--);}else {break;}} finally {lock.unlock();//解锁}}}
}

4.2 synchronized 与 Lock 的对比

  • Lock锁是显示锁(手动开启和关闭锁,别忘记关闭锁)、synchronized是隐式锁,出了作用域自动释放
  • Lock只有代码块锁,synchronized有代码块锁和方法锁
  • 使用Lock锁,JVM将花费较少的时间来调度线程,性能更好。并且具有更好的扩展性,可以完全人为控制获取锁,释放锁。
  • 优先使用顺序
    Lock > 同步代码块(已经进入了方法体,分配了相应资源)> 同步方法(在方法体之外)

五、线程协作——生产者消费者模式

1.线程通信

  • 应用场景 : 生产者和消费者问题

假设仓库中只能存放一件产品 , 生产者将生产出来的产品放入仓库 , 消费者将 仓库中产品取走消费 。
如果仓库中没有产品 ,则生产者将产品放入仓库 , 否则停止生产并等待 , 直到 仓库中的产品被消费者取走为止 。
如果仓库中放有产品 , 则消费者可以将产品取走消费 , 否则停止消费并等待 , 直到仓库中再次放入产品为止。

2.问题分析

这是一个线程同步问题 , 生产者和消费者共享同一个资源 , 并且生产者和消费者之 间相互依赖 , 互为条件 .

  • 对于生产者 , 没有生产产品之前 , 要通知消费者等待 . 而生产了产品之后 , 又需要马上通知消费者消费
  • 对于消费者 , 在消费之后 , 要通知生产者已经结束消费 , 需要生产新的产品 以供消费.
  • 在生产者消费者问题中 , 仅有synchronized是不够的
  • synchronized 可阻止并发更新同一个共享资源 , 实现了同步
  • synchronized 不能用来实现不同线程之间的消息传递 (通信)

3.线程通信方法

  • 均是Object类的方法 , 都只能在同步方法或者同步代码块中 使用,否则会抛出异常IllegalMonitorStateException

4.解决方法一

  • 并发协作模型 “ 生产者 / 消费者模式 ” —>管程法

生产者 : 负责生产数据的模块 (可能是方法 , 对象 , 线程 , 进程) ;
消费者 : 负责处理数据的模块 (可能是方法 , 对象 , 线程 , 进程) ;
缓冲区 : 消费者不能直接使用生产者的数据 , 他们之间有个 “ 缓冲区
生产者将生产好的数据放入缓冲区 , 消费者从缓冲区拿出数据

//思路//1.思考需要哪些对象?
// 生产 , 消费 , 产品 , 容器
//2.分工
/*生产者只管生产消费者只管消费鸡: 实体类容器 :容器添加数据.要判断容器是否满,满了等待消费者消费没有满,通知生产者生产容器减少数据判断还有没有数据, 没有数据的话,等待生产者生产消费完毕,通知生产者生产*/import java.sql.SQLOutput;//测试生产者和消费者问题
public class TestPC {public static void main(String[] args) {SynContainer synContainer = new SynContainer();new Productor(synContainer).start();new Consumer(synContainer).start();}
}//生产者
class Productor extends Thread{//需要向容器中加入产品SynContainer container;public Productor(SynContainer container){this.container = container;}@Overridepublic void run() {for (int i = 1; i < 100; i++) {//生产者添加产品container.push(new Chicken(i));System.out.println("生产者生产了"+i+"鸡");}}
}//消费者
class Consumer extends Thread{SynContainer container;public Consumer(SynContainer container){this.container = container;}@Overridepublic void run() {for (int i = 1; i < 100; i++) {//消费者拿走产品Chicken chicken = container.pop();System.out.println("消费者消费了"+chicken.id+"鸡");}}
}//缓冲区-->容器
class SynContainer{//容器Chicken[] chickens = new Chicken[10];//容器的计数器int num = 0;//生产者放入产品public synchronized void push(Chicken chicken) {//假如容易已经满了,就不用放,等待消费者消费if (num>=chickens.length){//等待消费者消费try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}//假如容器没有满 , 通知生产者生产System.out.println("num,,,,,"+num);chickens[num] = chicken;System.out.println("数组有多少个元素"+num);num++;//通知消费者消费this.notifyAll();}//消费者拿走产品public synchronized Chicken pop(){//假如容器空的,等待if (num<=0){//等待生产try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}num--;Chicken chicken = chickens[num];//通知生产者生产this.notifyAll();return chicken;}}//产品->鸡
class Chicken {int id;public Chicken(int id) {this.id = id;}
}

5.解决方法二

  • 并发协作模型 “ 生产者 / 消费者模式 ” —>信号灯法
//生产者消费2
//生产者--->演员
//消费者--->观众
//产品:信号灯--->电视----->声音public class TestPC2 {public static void main(String[] args) {TV tv = new TV();new Player(tv).start();new Watcher(tv).start();}
}//生产者
class Player extends Thread{TV tv;public Player(TV tv){this.tv = tv;}@Overridepublic void run() {for (int i = 0; i < 20; i++) {if (i%2==0){this.tv.play("节目:快乐大本营播放中");System.out.println();}else {this.tv.play("广告:抖音,记录美好生活");}}}
}//消费者
class Watcher extends Thread{TV tv;public Watcher(TV tv){this.tv = tv;}@Overridepublic void run() {for (int i = 0; i < 20; i++) {tv.watch();}}
}//电视
class TV{//演员说话 , 观众等待//观众观看 , 演员等待boolean flag = true;//说话String voice;//表演public synchronized void play(String voice){//演员等待if (!flag){try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("表演了"+voice);this.voice = voice;//让观众观看this.notifyAll();this.flag = !this.flag;}//观看public synchronized void watch(){//观众等待if (flag){try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("观众听到了: "+voice);//通知演员说话this.notifyAll();this.flag = !this.flag;}}

6.使用线程池

  • 背景:经常创建和销毁,使用太大的资源,消耗太大,并发的情况,影响性能。
  • 思路:提前创建好多个线程,放入线程池中,使用时直接获取,使用完放回池中。 可以避免频繁创建销毁、实现重复利用。类似生活中的公共交通工具。
  • 好处:
    1)提高响应速度(减少了创建新线程的时间)
    2)降低资源消耗(重复利用线程池中线程,不需要每次都创建)
    3)便于线程管理
  • JDK 5.0起提供了线程池相关API:ExecutorService 和 Executors
  • ExecutorService:真正的线程池接口。常见子类ThreadPoolExecutor

void execute(Runnable command) :执行任务/命令,没有返回值,一般用来执行Runnable
<返回值类型> Future<返回值类型> submit(Callable<返回值类型> task):执行任务,有返回值,一般又来执行 Callable
void shutdown() :关闭连接池

  • Executors:工具类、线程池的工厂类,用于创建并返回不同类型的线程池
//使用线程池
public class ThreadPool{public static void main(String[] args) {//创建一个线程池(池子大小)ExecutorService pool = Executors.newFixedThreadPool(10);//执行runnable接口实现类pool.execute(new MyThread4());pool.execute(new MyThread4());pool.execute(new MyThread4());pool.execute(new MyThread4());//关闭连接池pool.shutdown();}
}
class MyThread4 implements Runnable{@Overridepublic void run() {System.out.println("MyThread4");}
}

多线程——线程实现、线程状态、线程同步、线程通信、线程池相关推荐

  1. P576线程P582多线程P583startP584Runnable创建线程P58子线程应用P587退出P588方法P591守护线程P592线程7大状态P593同步P594互斥锁P596释放锁P598

    576线程-P598作业2 P576线程 P582多线程机制 public class Thread01 {public static void main(String[] args) {//创建Ca ...

  2. 线程分离属性,线程取消(状态,类型),线程取消例程函数

    目录 1.线程分离属性 2.线程取消(状态,类型) 3.线程取消例程函数 1.线程分离属性 默认情况下,线程启动后处于可接合状态(即未分离),此时的线程可以在退出时让其他线程接合以便释放资源,但若其他 ...

  3. 操作系统(3)-线程的六大状态、基于代码实战的线程创建及六个常用方法

    一.进程和线程的简介 进程的概念 进程是具有一定独立功能的程序关于某个数据集合上的一次运行活动,进程是系统进行资源分配和调度的一个独立单位. 进程中所包含的一个或多个执行单元成为线程.进程还拥有一个私 ...

  4. 【JAVA SE】第十六章 进程、线程、同步锁和线程锁的简介

    第十六章 进程.线程.同步锁和线程安全问题 文章目录 第十六章 进程.线程.同步锁和线程安全问题 一.进程 1.基本介绍 2.进程模型 二.线程 1.基本介绍 2.线程的生命周期 3.线程的优先级 4 ...

  5. java 线程交替输出,[java]java经典问题之线程交替打印数字

    问题 给出两个线程,要求两个线程交替打印从1到100,例如:A线程打印1,B线程打印2,A线程打印3...依次类推,直到打印到100 思路 这里主要是考察对java中wait/notifyAll机制的 ...

  6. android 多线程实现方式、并发与同步学习总结

    参考地址:http://blog.csdn.net/qq_30379689/article/details/72550701#面向对象和面向过程的区别 http://blog.csdn.net/csd ...

  7. Java多线程基础学习,Thread解读、java线程的状态、同步和异步、两阶段终止模式

    理论概述 单线程和多线程 为什么要使用多线程呢?多线程有什么好处呢? 如果在程序中,需要读写一个文件,该文件很大,那我们执行到该io操作时,cpu就会等待该io操作执行完才会继续运行下面的代码,进程调 ...

  8. Python 多线程总结(2)— 线程锁、线程池、线程数量、互斥锁、死锁、线程同步

    主要介绍使用 threading 模块创建线程的 3 种方式,分别为: 创建 Thread 实例函数 创建 Thread 实例可调用的类对象 使用 Thread 派生子类的方式 多线程是提高效率的一种 ...

  9. python多线程编程(2): 使用互斥锁同步线程

    上一节的例子中,每个线程互相独立,相互之间没有任何关系.现在假设这样一个例子:有一个全局的计数num,每个线程获取这个全局的计数,根据num进行一些处理,然后将num加1.很容易写出这样的代码: # ...

  10. java 多线程状态_总结Java中线程的状态及多线程的实现方式

    线程的状态线程状态图: 说明: 线程共包括以下5种状态. 1. 新建状态(New) : 线程对象被创建后,就进入了新建状态.例如,Thread thread = new Thread(). 2. 就绪 ...

最新文章

  1. winscp开启ftp_如何使用winscp,如何使用winscp连接FTP
  2. Atitit.工作流 与 规则引擎
  3. crtmpserver流媒体服务器的介绍与搭建
  4. eclipse中设置Linux编码环境,更改eclipse中console编码
  5. 四大科技巨头跟随者众 智能家居市场容量可观
  6. SOAP协议初级指南(2)
  7. 【MATLAB统计分析与应用100例】案例004:matlab调用smoothts函数对金融时间序列数据进行平滑处理
  8. python编程快速上手第三章_Python编程快速上手 往让繁琐工作自动化-6.6 习题(示例代码)...
  9. 第 11 章 装饰者设计模式
  10. 毕啸南专栏 | 对话百度王海峰:AI时代会产生新巨头
  11. 25 个超棒的 HTML5 JavaScript 游戏引擎开发库
  12. java生成四位数字验证码_简单的随机生成4个数字验证码的实现
  13. 程序员最常用的6大技术博客排行榜
  14. Slowloris DoS攻击的原理与简单实现
  15. 第二十三章 宋桓公自行其是讨苦吃 齐桓公连克宋郑震东方
  16. 漏洞分析---SSLv3降级加密协议Padding Oracle攻击(POODLE)技术分析
  17. Windows10 错误代码:0xc000007b 问题解决
  18. transform(转换)
  19. 在Servlet之前的CGI是个什么东西
  20. matlab 热传导方程,热传导方程有限差分法的MATLAB实现

热门文章

  1. TerminateProcess的使用问题
  2. vim 查找字符串和字符串替换
  3. ip route配置单个网关
  4. 作为一名软件测试工程师,需要具备哪些能力?(建议收藏/深度好文)
  5. 这个亚洲女强人带领这家全女性公司创造了历史!
  6. 斯坦福Nature论文宣布新突破:AI诊断皮肤癌达专家水平
  7. python制作动图、怎么运行_用Python2.7运行下面这个代码,但是出现了问题,请问如何可以解决,使之生成图像?...
  8. Filezilla搭建FTP服务器及Linux连接
  9. 注意,500本期刊已被科睿唯安标记,50本已被剔除,这些信号需警醒
  10. Python清空Redis的hash表的两种方法