synchronized互斥锁结合wait()、notify()方法使用，实现线程的阻塞以及线程调用案例

public class Test1 {int sum = 0 ;String str= "锁";//生产者public class production extends Thread{//重写run方法@Overridepublic void run() {//使用锁synchronized (str){//循环生产for (;;) {sum++;System.out.println("生产力"+sum);try {//避免输出过快，开启线程等待Thread.sleep(500);//判断总的数量if (sum==10){//随机唤醒一个锁,但因为生产者的线程没有停止，所以会继续执行str.notify();//Producer线程等待, 释放锁. 线程等待后续代码就不会继续执行,直到被唤醒str.wait();}} catch (InterruptedException e) {e.printStackTrace();}}}}}public class Consumer extends Thread{@Overridepublic void run() {synchronized (str){//存库为0, Consumer线程等待(不等待, Consumer线程先获得到锁会出现负消费)if(sum==0){try {str.wait();} catch (InterruptedException e) {e.printStackTrace();}}for (;;) {sum--;System.out.println("消费了"+(sum+1)+"个产品");try {Thread.sleep(500);//库存为10, 线程1等待, 释放锁System.out.println(sum);if(sum==0){try {//唤醒一个线程, Consumer线程并没有等待,所以会继续执行str.notify();//Consumer线程等待, 释放锁. 线程等待后续代码就不会继续执行,直到被唤醒str.wait();} catch (InterruptedException e) {e.printStackTrace();}}} catch (InterruptedException e) {e.printStackTrace();}}}}}public static void main(String[] args) {Test1 test1 = new Test1();production production = test1.new production();production.start();Consumer consumer = test1.new Consumer();consumer.start();}}

synchronized互斥锁结合wait()、notify()方法使用，实现线程的阻塞以及线程调用案例相关推荐

互斥锁mutex的使用方法
在线程实际运行过程中,我们经常需要多个线程保持同步.这时可以用互斥锁来完成任务:互斥锁的使用过程中,主要有pthread_mutex_init,pthread_mutex_destory,pthrea ...
多线程之互斥锁(mutex)的使用方法
关于读写锁可查看:多线程之读写锁(unique_lock与shared_lock) 多个线程访问同一资源时,为了保证数据的一致性,最简单的方式就是使用 mutex(互斥锁). 引用 cpprefere ...
进程互斥锁，队列，IPC进程间通信，生产者与消费者，线程，线程对象的属性，先行互斥锁...
进程互斥锁: 让并发变成串行, 牺牲了执行效率, 保证了数据安全.在程序并发执行时,需要修改数据时使用. 队列队列:先进先出相当于内存中产生一个队列空间,先进先出, 可以存放多个数据,但数 ...
java synchronized互斥锁使用
1.private static Object lock = new Object(); // static确保只有一把锁 2.public void increaseI() { synchr ...
C++ 线程同步之互斥锁
文章目录 1.简介 2.std::mutex 3.线程同步 4.std::lock_guard 5.std::recursive_mutex-少用 6.std::timed_mutex 1.简介进行 ...
互斥锁的概念和使用方法。
声明:转载别人的,觉得对自己有用.链接地址:http://blog.csdn.net/harry_lyc/article/details/6222920 在单线程条件下,由于对数据操作,在同样的时间下 ...
线程安全: 互斥锁和自旋锁(10种)
无并发,不编程.提到多线程就很难绕开锁?. iOS开发中较常见的两类锁: 1. 互斥锁: 同一时刻只能有一个线程获得互斥锁,其余线程处于挂起状态. 2. 自旋锁: 当某个线程获得自旋锁后,别的线程会一 ...
Java线程的挂起与恢复 wait(), notify()方法介绍
一, 什么是线程的挂起与恢复从字面理解也很简单. 所谓线程挂起就是指暂停线程的执行(阻塞状态). 而恢复时就是让暂停的线程得以继续执行.(返回就绪状态) 二, 为何需要挂起和恢复线程. 我们来看1个 ...
可重入锁(递归锁) 互斥锁属性设置
前言: 上一次刷博客的时候,看到了自旋锁,通过学习Linux内核,对自旋锁有了一定的了解.在学习的过程中看到这么一句话--自旋锁是不可递归的.自旋锁不可递归,难道有可以递归的锁?带着这个问题,我们来看 ...
你了解多线程自旋锁、互斥锁、递归锁等锁吗?
首先看一下问题引出,先看一些经典的问题. 多线程的隐患首先我们利用多线程的话肯定是好处多多,因为我们可以同时去做一些事情,大大的提高了效率.像我们下载视频的时候就可以同时下载多个视频,这样是节省了很 ...

synchronized互斥锁结合wait()、notify()方法使用，实现线程的阻塞以及线程调用案例

synchronized互斥锁结合wait()、notify()方法使用，实现线程的阻塞以及线程调用案例相关推荐

最新文章

热门文章