应付面试：面试管一般会问有过线程没有，你会在A的线程里面获取B线程的数据吗？
见图：（图1）
1.创建一个缓存池，用于线程管理
package test20140907.testthread3;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class ThreadPool {
private ThreadPool() {
}
private static ThreadPool instance;
public static ThreadPool getInstance() {
if (instance == null) {
instance = new ThreadPool();
}
return instance;
}
@SuppressWarnings("rawtypes")
static Future future =null;
static ExecutorService cachedService;
public void init() {
cachedService = Executors.newFixedThreadPool(1);
cachedService.execute(new RunableA());
}
class RunableA implements Runnable {
@Override
public void run() {
TaskFirst tf =new TaskFirst();
tf.getValue();
}
}
}
2.任务下发
package test20140907.testthread3;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class TaskFirst {
static double d;
Lock sendlock = new ReentrantLock();
Condition sendlockCondition =sendlock.newCondition();
public void addValue(double doub){
sendlock.lock();
try {
sendlockCondition.await(5,TimeUnit.SECONDS);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("getValue d: "+ d);
sendlock.unlock();
}
public void getValue(){
sendlock.lock();
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.d= 5.5;
System.out.println("addValue d: "+ d);
sendlockCondition.signal();
sendlock.unlock();
}
}
3.测试 模拟一个执行任务的线程获取数据，该线程犹如网络延迟耗费3s 然后接收任务的线程等待5s 获取数据 完成一次同步的通讯
package test20140907.testthread3;
public class Test {
public static void main(String[] args) {
ThreadPool.getInstance().init();
TaskFirst tf =new TaskFirst();
tf.addValue(2);
}
}
捐助开发者
在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（右上角的爱心标志，支持支付宝和PayPal捐助），没钱捧个人场，谢谢各位。
谢谢您的赞助，我会做的更好！
