java 线程学习(2)(一)

2014-11-24 03:14:05 · 作者: · 浏览: 3

/*

//线程间通信:就是多个线程在线程在操作同一个资源,但是操作的动作不同

class Res

{

String name;

String sex;

}

class Input implements Runnable

{

private Res r;

Object obj=new Object();

Input(Res r)

{

this.r=r;

}

public void run()

{

int x=0;

while(true)

{

synchronized(Input.class) //或者是Input.class(本类中唯一的对象) 而下面必须也是Input.class

{ //总之上下两个线程锁必须一致 可以是Input.class,Output.class,r

if(x==0)

{

r.name="mike";

r.sex="man";

}

else

{

r.name="丽丽";

r.sex="女女女女";

}

x=(x+1)%2;

}

}

}

}

class Output implements Runnable

{

private Res r;

Output(Res r)

{

this.r=r;

}

public void run()

{

while(true)

synchronized(Input.class)

{

System.out.println(r.name+"----"+r.sex);

}

}

}

class Test

{

public static void main(String[] args)

{

Res r=new Res();

Input in=new Input(r);

Output out=new Output(r);

Thread t1=new Thread(in);

Thread t2=new Thread(out);

t1.start();

t2.start();

}

}

*/

/*

//wait,notify,notifyAll都使用在同步中,因为要对持有监视器(锁)的线程操作。

//所以要使用在同步中,因为只有同步才具有锁。

//为什么这些操作线程的方法要定义在Object中?

//因为这些方法在操作同步中线程时,都必须要标识它们所操作线程只有的锁,

//只有同一个锁上的被等待线程,可以被同一个锁上的notify唤醒。

//不可以对不同锁中线程唤醒。

//也就是说,等待和唤醒必须是同一个锁,而锁可以是任意对象,所以可以被任意对象调用的方法定义Object中

class Res

{

String name;

String sex;

boolean flag=false;

}

class Input implements Runnable

{

private Res r;

Object obj=new Object();

Input(Res r)

{

this.r=r;

}

public void run()

{

int x=0;

while(true)

{

synchronized(Input.class)

{

if(r.flag) //等待

try{Input.class.wait();}catch(Exception e){}//使用Input.class或者Output.class或者r

if(x==0)

{

r.name="mike";

r.sex="man";

}

else

{

r.name="丽丽";

r.sex="女女女女";

}

x=(x+1)%2;

r.flag=true;

Input.class.notify();// 唤醒 线程池中线程,唤醒第一个等待的

}

}

}

}

class Output implements Runnable

{

private Res r;

Output(Res r)

{

this.r=r;

}

public void run()

{

while(true)

synchronized(Input.class)

{

if(!r.flag)

try{Input.class.wait();}catch(Exception e){}

System.out.println(r.name+"----"+r.sex);

r.flag=false;

Input.class.notify();

}

}

}

class Test

{

public static void main(String[] args)

{

Res r=new Res();

Input in=new Input(r);

Output out=new Output(r);

Thread t1=new Thread(in);

Thread t2=new Thread(out);

t1.start();