线程通信

Posted 2020-11-19 shenhengjia

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

class person
{
　　private String name;
　　private String xingbie;
　　boolean panduan=false;
　　int y=0;
　　Lock l=new ReentrantLock();//创建锁。
　　Condition c1=l.newCondition();
　　Condition c2=l.newCondition();
　　public String getName()

　　{
　　　　return name;
　　}
　　public void setName(String name)

　　 {
　　　　this.name = name;
　　}
　　public String getXingbie()

　　 {
　　　　return xingbie;
　　}
　　public void setXingbie(String xingbie)

　　{
　　　　this.xingbie = xingbie;
　　}


　　public void fangru() throws InterruptedException
　　{
　　　　l.lock();
　　　　try

　　　　{

　　　　　　while(panduan)

　　　　　　{
　　　　　　　　c1.await();
　　　　　　}
　　　　　　if(y==0)
　　　　　　{
　　　　　　　　setName("张三");
　　　　　　　　setXingbie("男");
　　　　　　}
　　　　else
　　　　{
　　　　　　setName("李四");
　　　　　　setXingbie("女");
　　　　}
　　　　y=(y+1)%2;
　　　　panduan=true;
　　　　c2.signal();
　　　　}
　　　　finally
　　　　{
　　　　　　l.unlock();
　　　　}

　　}

　　public void quchu() throws InterruptedException
　　{
　　　　l.lock();
　　　　try{
　　　　　　while(!panduan)
　　　　　　{
　　　　　　　　c2.await();
　　　　　　}
　　　　　　System.out.println(this.getName()+"----"+this.getXingbie());
　　　　　　panduan=false;
　　　　　　c1.signal();
　　　　　}
　　　　finally
　　　　{
　　　　　　l.unlock();
　　　　}

　　}

}

class du implements Runnable
{
　　person p;
　　du(person p)
　　{
　　　　this.p=p;
　　}

　　public void run()

　　{
　　　　while(true)
　　　　{
　　　　　　try

　　　　　　 {
　　　　　　　　p.fangru();
　　　　　　} catch (InterruptedException e)

　　　　　　 {
　　　　　　　　e.printStackTrace();
　　　　　　}
　　　　}
　　}
}
class qu implements Runnable
{
　　person p;
　　qu(person p)
　　{
　　　　this.p=p;
　　}
　　public void run()

　　{
　　　　while(true)
　　　　{
　　　　　　try

　　　　　　 {
　　　　　　　　p.quchu();
　　　　　　}

　　　　　　 catch (InterruptedException e)

　　　　　　 {
　　　　　　　　e.printStackTrace();
　　　　　　}
　　　　}
　　}
}

public class xianchengtongxin

{

　　public static void main(String[] args)

　　 {

　　　　person p=new person();
　　　　du du=new du(p);
　　　　qu qu=new qu(p);
　　　　Thread t1=new Thread(du);
　　　　Thread t2=new Thread(qu);
　　　　Thread t3=new Thread(du);
　　　　Thread t4=new Thread(qu);
　　　　t1.start();
　　　　t2.start();
　　　　t3.start();
　　　　t4.start();
　　}

}