多线程中的线程通信以及死锁问题
2017-09-04 21:04
471 查看
多线程中的线程通信问题:
先列出线程中释放锁的操作:
1.当前线程的同步方法、同步代码块执行结束
2.当前线程在同步代码块,同步方法中遇到break、return、终止了该大妈快,方法的执行
3.出现了为处理的error或者exception,导致异常结束
4.当前线程在同步代码块,同步方法中执行了线程对象的wait()方法,当前线程暂停,并释放锁。
线程的通信使用的方法:wait()、notify()、notifyAll()----------这三个方法都是Object里的方法,不是线程中的方法
一个关于线程通信的实例:实现两个储户往同一个账户中交替存钱,每个储户存三次,每次存完打印账户中余额。
共享资源类:Account
public class Account {
int balance;
public Account(){}
//synchronized:同步方法,解决线程中的安全问题
public synchronized void saveMonny(int atm){
notify();//唤醒其他挂起的线程
balance += atm;
try {
Thread.currentThread().sleep(10);//当前线程沉睡10毫秒,放大不加同步锁时的操作
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+":"+balance);
try {
if(balance<6000){
wait();//账户未存满6000,当前线程挂起,并释放锁
}else {
//账户中存满6000,让当前线程执行结束,释放锁
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
储户类:Customer
public class Customer implements Runnable{
Account account; //线程中的共享资源(多个线程共同操作的对象)
public Customer(Account account){
this.account = account;
}
@Override
public void run() {
for(int i=0;i<3;i++){
account.saveMonny(1000);
}
}
}测试类:
public class AccountTest {
public static void main(String[] args) {
Account account = new Account();
Customer customer = new Customer(account);
Thread t1 = new Thread(customer);
Thread t2 = new Thread(customer);
t1.setName("甲");
t2.setName("乙");
t1.start();
t2.start();
}
}
运行结果:
![](https://oscdn.geek-share.com/Uploads/Images/Content/201709/e999bd80442f8a296ca75f77447cb445)
这样就利用线程通信实现了甲和乙往同一个账户中交替存钱。
线程中的死锁问题:
什么是死锁?
不同的线程分别占用对方需要的同步资源不放弃,都在等待对方放弃自己需要的同步资源,就形成了线程的死锁。
一个死锁的实例:
public class DeadLock {
static StringBuffer s1 = new StringBuffer();
static StringBuffer s2 = new StringBuffer();
public static void main(String[] args) {
new Thread(){
@Override
public void run() {
synchronized (s1){ //当前线程持s1锁,同步代码块走完则释放该锁
s1.append("A");
try {
Thread.currentThread().sleep(10);//当前线程沉睡10毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
synchronized (s2){ //当前线程再持一把s2锁,但被下面线程拿着,形成死锁
s2.append("B");
System.out.println(Thread.currentThread().getName()+":"+s1);
System.out.println(Thread.currentThread().getName()+":"+s2);
}
}
}
}.start();
new Thread(){
@Override
public void run() {
synchronized (s2){ //由于之前线程沉睡10毫秒,当前线程拿到s2锁
s1.append("C");
try {
Thread.currentThread().sleep(10);//沉睡10毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
synchronized (s1){ //需要拿到s1锁,但被上面线程拿着,形成死锁
s2.append("D");
System.out.println(Thread.currentThread().getName()+":"+s1);
System.out.println(Thread.currentThread().getName()+":"+s2);
}
}
}
}.start();
}
}
运行上面程序,会发现程序处于阻塞状态,即两个线程都在等待对方释放自己所需要的同步资源,形成死锁
先列出线程中释放锁的操作:
1.当前线程的同步方法、同步代码块执行结束
2.当前线程在同步代码块,同步方法中遇到break、return、终止了该大妈快,方法的执行
3.出现了为处理的error或者exception,导致异常结束
4.当前线程在同步代码块,同步方法中执行了线程对象的wait()方法,当前线程暂停,并释放锁。
线程的通信使用的方法:wait()、notify()、notifyAll()----------这三个方法都是Object里的方法,不是线程中的方法
一个关于线程通信的实例:实现两个储户往同一个账户中交替存钱,每个储户存三次,每次存完打印账户中余额。
共享资源类:Account
public class Account {
int balance;
public Account(){}
//synchronized:同步方法,解决线程中的安全问题
public synchronized void saveMonny(int atm){
notify();//唤醒其他挂起的线程
balance += atm;
try {
Thread.currentThread().sleep(10);//当前线程沉睡10毫秒,放大不加同步锁时的操作
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+":"+balance);
try {
if(balance<6000){
wait();//账户未存满6000,当前线程挂起,并释放锁
}else {
//账户中存满6000,让当前线程执行结束,释放锁
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
储户类:Customer
public class Customer implements Runnable{
Account account; //线程中的共享资源(多个线程共同操作的对象)
public Customer(Account account){
this.account = account;
}
@Override
public void run() {
for(int i=0;i<3;i++){
account.saveMonny(1000);
}
}
}测试类:
public class AccountTest {
public static void main(String[] args) {
Account account = new Account();
Customer customer = new Customer(account);
Thread t1 = new Thread(customer);
Thread t2 = new Thread(customer);
t1.setName("甲");
t2.setName("乙");
t1.start();
t2.start();
}
}
运行结果:
这样就利用线程通信实现了甲和乙往同一个账户中交替存钱。
线程中的死锁问题:
什么是死锁?
不同的线程分别占用对方需要的同步资源不放弃,都在等待对方放弃自己需要的同步资源,就形成了线程的死锁。
一个死锁的实例:
public class DeadLock {
static StringBuffer s1 = new StringBuffer();
static StringBuffer s2 = new StringBuffer();
public static void main(String[] args) {
new Thread(){
@Override
public void run() {
synchronized (s1){ //当前线程持s1锁,同步代码块走完则释放该锁
s1.append("A");
try {
Thread.currentThread().sleep(10);//当前线程沉睡10毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
synchronized (s2){ //当前线程再持一把s2锁,但被下面线程拿着,形成死锁
s2.append("B");
System.out.println(Thread.currentThread().getName()+":"+s1);
System.out.println(Thread.currentThread().getName()+":"+s2);
}
}
}
}.start();
new Thread(){
@Override
public void run() {
synchronized (s2){ //由于之前线程沉睡10毫秒,当前线程拿到s2锁
s1.append("C");
try {
Thread.currentThread().sleep(10);//沉睡10毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
synchronized (s1){ //需要拿到s1锁,但被上面线程拿着,形成死锁
s2.append("D");
System.out.println(Thread.currentThread().getName()+":"+s1);
System.out.println(Thread.currentThread().getName()+":"+s2);
}
}
}
}.start();
}
}
运行上面程序,会发现程序处于阻塞状态,即两个线程都在等待对方释放自己所需要的同步资源,形成死锁
相关文章推荐
- Android(java)学习笔记70:同步中的死锁问题以及线程通信问题
- 黑马程序员------多线程(No.2)(死锁、线程间通信、生产者消费者问题)
- 多线程(线程间通信-多生产者多消费者问题-JDK1.5解决办法-范例),停止线程,线程中方法的区别,匿名内部类实现多线程,线程总结
- 多线程在Android中的应用以及线程间的通信
- .net学习之多线程、线程死锁、线程通信 生产者消费者模式、委托的简单使用、GDI(图形设计接口)常用的方法
- 黑马程序员自学笔记————多线程 线程间通信之生产者消费者问题;
- 死锁、进程通信以及进程线程的区别
- 【面经笔记】线程、多线程 - 死锁、读写、消费者问题、TLS【续2】
- C++多线程编程以及epoll处理socket通信时多端口问题
- 多线程编程之线程死锁问题 转载
- 黑马程序员 学习笔记六:线程间的通信以及通信安全问题
- java多线程程序设计二、线程返回值,优先级以及暂停的问题
- 黑马程序员-19-java基础-多线程(2)-死锁与线程间通信(synchronized与Lock的区别及各自用法)
- 多线程之Map:Hashtable HashMap 以及ConcurrentHashMap的线程安全问题
- JAVA之旅(十四)——静态同步函数的锁是class对象,多线程的单例设计模式,死锁,线程中的通讯以及通讯所带来的安全隐患,等待唤醒机制
- JavaSE第一百零四讲:哲学家就餐问题、死锁与使用wait及notify方法实现线程之间的相互通信
- 29-多线程(线程间通信-多生产者多消费者问题-JDK1.5新特性-Condition).1 2 31-多线程(线程间通信-多生产者多消费者问题-JDK1.5解决办法-范例). 1 2
- 多线程编程之线程死锁问题
- JAVA之旅(十四)——静态同步函数的锁是class对象,多线程的单例设计模式,死锁,线程中的通讯以及通讯所带来的安全隐患,等待唤醒机制
- 多线程(线程间通信-多生产者多消费者问题-JDK1.5新特性-Lock