线程管道代码,Java代码库,德仔网

代码语言

代码分类

【Java】线程管道

作者:举起手来 / 发布于2012/6/25/ 490

线程管道

<div>package wait;</div>
import java.util.concurrent.TimeUnit;</div>
<div>/**
* 启动两个线程，这两个线程能够交换数据
*/
public class Test {
public static void main(String[] args) throws InterruptedException {
final Test t = new Test();
new Thread(new Runnable() {
public void run() {
t.await();
}
}).start();
TimeUnit.MILLISECONDS.sleep(100);
new Thread(new Runnable() {
public void run() {
t.asingle("12");
}
}).start();
}
<div>String s = null;
boolean f = false;</div>
<div>//等待端，等待接受数据
synchronized void await() {//process首先等待，直到connector把f变成true
while (!f) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
f = false;
System.out.println(Thread.currentThread() + ",await,s:" + s);
notifyAll();
System.out.println("ok");
}
//发送端，
synchronized void asingle(String str) {//connector不会等待；但是后面的
while (f) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.s = str;//存储s，线程交换数据
f = true;
notifyAll();
System.out.println(Thread.currentThread() + ",asingle");
}
}
</div>

试试其它关键字

同语言下

可能有用的

举起手来贡献的其它代码(4)