class Buffer1 //缓冲区
{ private int value;
void put(int i)
{ value = i;
}
int get()
{ return value;
}
}
class Sender1 extends Thread //发送线程
{ private Buffer1 bf;
public Sender1(Buffer1 bf)
{ this.bf = bf;
}
public void run( )
{ for (int i=1;i<6;i++)
{ bf.put( i );
System.out.println("Sender put, " + i );
try
{ sleep(1);
}
catch(InterruptedException e)
{ System.out.println(e.getMessage());
}
}
}
public static void main (String args[])
{ Buffer1 bf = new Buffer1();
(new Sender1(bf)).start();
(new Receiver1(bf)).start();
}
}
class Receiver1 extends Thread //接受线程
{ private Buffer1 bf;
public Receiver1(Buffer1 bf)
{ this.bf = bf ;
}
public void run( )
{ for (int i=1; i<6;i++)
{ System.out.println("\t\t Receiver get, " + bf.get()) ;
try
{ sleep(1);
}
catch(InterruptedException e)
{ System.out.println(e.getMessage());
}
}
}
}
D:\myjava>java Sender1
Sender put, 1
Receiver get, 1
Sender put, 2
Receiver get, 2
Sender put, 3
Receiver get, 3
Sender put, 4
Receiver get, 4
Sender put, 5
Receiver get, 5
D:\myjava>java Sender1
Sender put, 1
Receiver get, 1
Sender put, 2
Sender put, 3
Receiver get, 3
Sender put, 4
Sender put, 5
Receiver get, 5
Receiver get, 5
Receiver get, 5
D:\myjava>java Sender1
Sender put, 1
Sender put, 2
Receiver get, 2
Sender put, 3
Receiver get, 3
Sender put, 4
Receiver get, 4
Sender put, 5
Receiver get, 5
Receiver get, 5
D:\myjava>java Sender1
Sender put, 1
Receiver get, 1
Sender put, 2
Receiver get, 2
Sender put, 3
Receiver get, 3
Sender put, 4
Receiver get, 4
Receiver get, 4
Sender put, 5