线程通信机制-创新互联
线程通讯
概念:
当前文章:线程通信机制-创新互联
当前路径:http://scgulin.cn/article/iopse.html
多个线程在处理同一个资源,但是处理的动作(线程的任务)却不相同。
创新互联公司专注于网站建设,为客户提供网站建设、成都网站建设、网页设计开发服务,多年建网站服务经验,各类网站都可以开发,成都品牌网站建设,公司官网,公司展示网站,网站设计,建网站费用,建网站多少钱,价格优惠,收费合理。线程状态new | 线程刚被创建,但未并被启动,还没被调用Start()方法 |
Runnable | 线程可以在java虚拟器中运行的状态可能正在运行自己代码,也可能没有,这取决于操作系统处理器。 |
Blocked | 当一 个线程试图获取一 个对象锁, 而该对象锁被其他的线程持有,则该线程进入Blocked状态 |
Waiting | 个线程在等待另一 一个线程执行一个(唤醒)动作时,该线程进入Waiting状态。 |
Timed Waiting | 同waiting状态,有几个方法有超时参数,调用他们将进入Timed Waiting状态。 |
Teminated | 因为run方法正常退出而死亡,或者因为没有捕捉的异常终止了run方法而死亡。 |
等待唤醒机制 什么是等待唤醒机制:
等待唤醒机制就是在一个线程进行了规定操作后,另一个线程就进入等待状态(wait()),
等待刚刚进行规定操作的线程执行完他们的指定代码后,再将处于等待状态的这个线程唤醒(notify());
在有多个线程进行等待的时候,如果需要我们可以使用notifyAll()来唤醒所有的等待线程。
等待通知机制的方法notify():
通知一个在对象上等待的线程,使其从wait方法唤醒。而唤醒的前提是该线程获取到了对象的锁。没有获取到的线程依旧处以WAITING状态。
notifyAll():
通知所有等待在该对象上的线程。
图解例题——早餐店包子售卖wait():
调用该方法的线程进入WAITING状态,只有等待另外线程的通知或被interrupted中断才会被唤醒。需要注意的是,调用wait()方法后,会释放对象的锁。
包子资源类
public class BaoZi {
String name;//包子的名称
Boolean flag;//包子的状态(true表示存在 false 表示不存在)
}
早餐店线程
public class ZaoCanDian extends Thread {
BaoZi baoZi;
//构造函数:用来指定线程的名称和操作资源
public ZaoCanDian(String name, BaoZi baoZi) {
super(name);
this.baoZi = baoZi;
}
public void run() {
String threadName = Thread.currentThread().getName();
int count = 0;
while (true) {
synchronized (baoZi) {
count++;
if (count >10) {
break;
}
if (baoZi.flag) {//如果包子存在
try {
baoZi.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
//如果包子不存在
System.out.println(threadName + "开始制作" + baoZi.name);
baoZi.flag=true;//更改包子状态
baoZi.notify();//唤醒同一资源下的其他线程
}
}
}
}
}
吃货线程
public class ChiHuo extends Thread{
BaoZi baoZi;
//构造函数:用来指定线程的名称和操作资源
public ChiHuo(String name,BaoZi baoZi){
super(name);
this.baoZi=baoZi;
}
public void run(){
String threadName=Thread.currentThread().getName();
int count=0;
while(true){
synchronized (baoZi){
count++;
if (count>10){
break;
}
if(baoZi.flag){//如果包子存在
System.out.println(threadName+"开始吃"+baoZi.name);
baoZi.flag=false;//修改状态
baoZi.notify();//唤醒其他资源状态
}else{
//如果包子不存在
try {
baoZi.wait();//进入等待状态
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
早餐店和吃货间线程的转换
public class ThreadTest {
public static void main(String[] args) {
//定义资源对象
BaoZi baoZi=new BaoZi();
baoZi.name="韭菜 鸡蛋 五花肉 豆腐";
baoZi.flag=true;
//定义两个线程,起名字且操作同一对象
ChiHuo ch=new ChiHuo("空旧黎梦",baoZi);
ZaoCanDian zcd=new ZaoCanDian("豪华",baoZi);
//启动线程
zcd.start();
ch.start();
}
}
你是否还在寻找稳定的海外服务器提供商?创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源,准确流量调度确保服务器高可用性,企业级服务器适合批量采购,新人活动首月15元起,快前往官网查看详情吧
当前文章:线程通信机制-创新互联
当前路径:http://scgulin.cn/article/iopse.html