Java编程之多线程死锁与线程间通信简单实现代码
死锁定义
死锁是指两个或者多个线程被永久阻塞的一种局面，产生的前提是要有两个或两个以上的线程，并且来操作两个或者多个以上的共同资源；我的理解是用两个线程来举例，现有线程A和B同时操作两个共同资源a和b，A操作a的时候上锁LockA,继续执行的时候，A还需要LockB进行下面的操作，这个时候b资源在被B线程操作，刚好被上了锁LockB，假如此时线程B刚好释放了LockB则没有问题，但没有释放LockB锁的时候，线程A和B形成了对LockB锁资源的争夺，从而造成阻塞，形成死锁；具体其死锁代码如下：
publicclassMyDeadLockTest{
publicstaticvoidmain(String[]args){
Objectobj1=newObject();
Threadthread1=newThread(newDeadRes(true,obj1));
Threadthread2=newThread(newDeadRes(false,obj1));
thread1.start();
thread2.start();
}
}
classDeadResimplementsRunnable{
booleanflag;
Objectobj;
publicDeadRes(booleanflag,Objectobj1){
this.flag=flag;
this.obj=obj1;
}
@Override
publicvoidrun(){
if(flag){
synchronized(DeadRes.class){
System.out.println(Thread.currentThread().getName()+"acquielockisDeadRes.class");
synchronized(obj){
System.out.println(Thread.currentThread().getName()+"acquielockisobj");
}
}
}else{
synchronized(obj){
System.out.println(Thread.currentThread().getName()+"acquielockisobj");
synchronized(DeadRes.class){
System.out.println(Thread.currentThread().getName()+"acquielockisDeadRes.class");
}
}
}
}
}
执行结果如下图：
Thread-1acquielockisobj Thread-0acquielockisDeadRes.class
当然每次执行的结果不一样，有可能是一种和谐状态，没有发生死锁，此时为保证每次死锁，可以让run()方法中，执行while(true)循环，这样保证了每次必定发生死锁；当然实际应用中，我们应该尽量避免死锁，当有多线程操作多个共同资源的时候，避免发生同一锁对象的同步嵌套。
线程间的通讯—-生产者与消费者模式
1、让两个线程交替进行操作，当生产了一个数字后，紧接着消费一个，首先采用Object对象中的wait-notify来实现，具体代码如下:
publicclassThreadProConsume{
publicstaticvoidmain(String[]args){
Productproduct=newProduct();
Threadthread1=newThread(newProducer(product));
Threadthread2=newThread(newConsumer(product));
thread1.start();
thread2.start();
}
}
classProduct{
Stringname;
privateintcount=1;
booleanflag=false;
publicsynchronizedvoidset(Stringname){
if(flag){
try{
this.wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
this.name=name+"--"+count++;
flag=true;
System.out.println(Thread.currentThread().getName()+"producenum:"+this.name);
this.notify();
}
publicsynchronizedvoidout(){
if(!flag){
try{
this.wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"consumenumis:"+this.name);
flag=false;
this.notify();
}
}
classProducerimplementsRunnable{
Productres;
publicProducer(Productproduct){
this.res=product;
}
@Override
publicvoidrun(){
while(true){
res.set("guyue");
}
}
}
classConsumerimplementsRunnable{
Productres;
publicConsumer(Productproduct){
this.res=product;
}
@Override
publicvoidrun(){
while(true){
res.out();
}
}
}
执行结果如图：
Thread-1consumenumis:guyue--3938 Thread-0producenum:guyue--3939 Thread-1consumenumis:guyue--3939 Thread-0producenum:guyue--3940 Thread-1consumenumis:guyue--3940 Thread-0producenum:guyue--3941 Thread-1consumenumis:guyue--3941
当超过两个以上线程操作的时候，这里需要在set()与out()方法中的if判断改为while，并且notif方法，改为notifyAll()，这样多个线程操作的时候，便可以交替进行，具体代码如下：
publicclassThreadProConsume{
publicstaticvoidmain(String[]args){
Productproduct=newProduct();
Threadthread1=newThread(newProducer(product));
Threadthread3=newThread(newProducer(product));
Threadthread2=newThread(newConsumer(product));
Threadthread4=newThread(newConsumer(product));
thread1.start();
thread3.start();
thread2.start();
thread4.start();
}
}
classProduct{
Stringname;
privateintcount=1;
booleanflag=false;
publicsynchronizedvoidset(Stringname){
while(flag){
try{
this.wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
this.name=name+"--"+count++;
flag=true;
System.out.println(Thread.currentThread().getName()+"producenum:"+this.name);
this.notifyAll();
}
publicsynchronizedvoidout(){
while(!flag){
try{
this.wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"consumenumis:"+this.name);
flag=false;
this.notifyAll();
}
}
执行结果如下：
Thread-0producenum:guyue--50325 Thread-2consumenumis:guyue--50325 Thread-1producenum:guyue--50326 Thread-3consumenumis:guyue--50326 Thread-0producenum:guyue--50327 Thread-2consumenumis:guyue--50327 Thread-1producenum:guyue--50328 Thread-3consumenumis:guyue--50328
2、采用Lock-Condition方法实现如下：
classProduct{
Stringname;
privateintcount=1;
booleanflag=false;
Locklock=newReentrantLock();
Conditionconditon=lock.newCondition();
publicvoidset(Stringname){
try{
lock.lock();
while(flag){
conditon.await();
}
this.name=name+"--"+count++;
flag=true;
System.out.println(Thread.currentThread().getName()+"producenum:"+this.name);
conditon.signalAll();
}catch(Exceptione){
}finally{
lock.unlock();
}
}
publicvoidout(){
try{
lock.lock();
while(!flag){
conditon.await();
}
flag=false;
System.out.println(Thread.currentThread().getName()+"consumernumis:"+this.name);
conditon.signalAll();
}catch(Exceptione){
}finally{
lock.unlock();
}
}
}
执行结果如下：
Thread-0producenum:guyue--20305 Thread-3consumernumis:guyue--20305 Thread-1producenum:guyue--20306 Thread-2consumernumis:guyue--20306 Thread-0producenum:guyue--20307 Thread-3consumernumis:guyue--20307 Thread-1producenum:guyue--20308 Thread-2consumernumis:guyue--20308
以上就是本文关于Java编程之多线程死锁与线程间通信简单实现代码的全部内容，希望对大家有所帮助。关于Java多线程以及线程间通信的例子，本站还有几篇文章可以参考：
详解java中的互斥锁信号量和多线程等待机制、Java多线程编程小实例模拟停车场系统、Java网络编程基础篇之单向通信
如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！