线程通信机制-创新互联

线程通讯 概念:

多个线程在处理同一个资源,但是处理的动作(线程的任务)却不相同。 

创新互联公司专注于网站建设,为客户提供网站建设、成都网站建设、网页设计开发服务,多年建网站服务经验,各类网站都可以开发,成都品牌网站建设,公司官网,公司展示网站,网站设计,建网站费用,建网站多少钱,价格优惠,收费合理。线程状态
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://cdiso.cn/article/iopse.html

其他资讯