java线程饥饿死锁thread starvation lock_JAVA_编程开发_程序员俱乐部

class="java">
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

class TaskOne implements Callable<String> {
    // 模拟中间人，存放任务结果
    private StringBuilder sb;

    public TaskOne(StringBuilder sb) {
        this.sb = sb;
    }
    @Override
    public String call() throws Exception {
        synchronized (sb) {
            // 这个任务要等另一个任务完成，中间人没有获取到另一个任务的结果的时候
            // 此任务要一直等待
            while (sb.length() == 0) {
                sb.wait();
            }
        }
        sb.append("哈哈，task one终于等到task two运行完成了~~ task one结束");
        return sb.toString();
    }

}

class TaskTwo implements Callable<String> {
    // 模拟中间人，任务结果放在这个里面
    private StringBuilder sb;
    public TaskTwo(StringBuilder sb) {
        this.sb = sb;
    }
    @Override
    public String call() throws Exception {
        synchronized (sb) {
            // 任务运行结果给中间人
            sb.append("task two result");
            sb.notify();
        }
        return sb.toString();
    }

}
public class Test {
    // 注意exec是单线程
    static final ExecutorService exec = Executors.newSingleThreadExecutor();

    public static void main(String[] args) throws Exception {
        // 模拟中间人，存放任务结果
        StringBuilder sb = new StringBuilder();

        TaskOne taskOne = new TaskOne(sb);
        TaskTwo taskTwo = new TaskTwo(sb);

        long begin = System.currentTimeMillis();
        // 先提交 taskOne， taskOne要等待taskTwo的运行结果
        Future<String> one = exec.submit(taskOne);
        // 再把taskTwo放入线程池运行
        Future<String> two = exec.submit(taskTwo);
        // 获取taskOne结果，但如果exec是个单线程的线程池
        // taskOne等待taskTwo的结果，可taskTwo却要等到taskOne运行结束
        // 才可以运行，造成了死锁，taskTwo永远不能获得cpu的运行,成饥饿状态
        String s1 = one.get();
        String s2 = two.get();

        System.out.println(s2);
        System.out.println(s1);
        long end = System.currentTimeMillis();
        System.out.println(end - begin);

        // exec.shutdownNow();
    }

}