jashdf123 2020-04-09 23:57 采纳率: 25%
浏览 238

Java的线程问题互锁问题

我创建了两个线程,共同请求两个资源 Object1 和 Object2。线程1占用O1然后请求
O2;同理 线程2 占用 O2 请求 O1,为了防止线程一下子走完从而没有一直保持占用资源的状态,我还添加了一个倒计时。

可是当线程2明显占用了资源2的时候,线程1还是能够获取到资源2.请问这是为什么呢?

public class DeadLockThreadDemo {

    // 定义两个资源
    public static Object resource01 = new Object();
    public static Object resource02 = new Object();

    public static void main(String[] args) {
        /*ExecutorService executorService = Executors
                .newFixedThreadPool(3, new MyThreadFactory("Gary Thread pool"));
        executorService.execute(new TakeResource1(resource01, resource02));
        executorService.execute(new TakeResource2(resource01, resource02));*/
        Thread thread1 = new Thread(new TakeResource1(resource01, resource02));
        Thread thread2 = new Thread(new TakeResource2(resource01, resource02));
        thread1.start();
        thread2.start();
    }
}

class TakeResource1 implements Runnable{

    final Object resource1;
    final Object resource2;
    public TakeResource1(Object resource1, Object resource2) {
        this.resource1 = resource1.toString();
        this.resource2 = resource2.toString();
    }

    @Override
    public void run() {

        synchronized (resource1)
        {
            System.out.println("线程" + Thread.currentThread().getName() + " 占用资源 " + resource1 + " 请求 " +resource2 + " 线程状态:" + Thread.currentThread().getState());

            synchronized (resource2) {
                System.out.println("线程" + Thread.currentThread().getName() + " 成功占用 " + resource2);
            }
        }
    }
}

class TakeResource2 implements Runnable{

    final Object resource1;
    final Object resource2;
    public TakeResource2(Object resource1, Object resource2) {
        this.resource1 = resource1.toString();
        this.resource2 = resource2.toString();
    }

    @Override
    public void run() {
        synchronized (resource2)
        {
            System.out.println("线程" + Thread.currentThread().getName()  + " 占用资源 " + resource2 + " 请求 " + resource1);

            try {
                for (int i = 10; i > 0; i--) {
                    System.out.println(Thread.currentThread().getName() + " 线程占用了" + resource2 + " 开始休眠:" + i);
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (resource1) {
                System.out.println("线程" + Thread.currentThread().getName() + " 成功占用 " + resource1);

            }
        }
    }
}

图片说明

  • 写回答

3条回答 默认 最新

  • UFO_SERIESOFSOFT 2020-04-10 09:36
    关注

    加锁需要使用同一个实例

    评论

报告相同问题?

悬赏问题

  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog