为了账号安全,请及时绑定邮箱和手机立即绑定

Java中如何使一个线程进入阻塞态?

Java中如何使一个线程进入阻塞态?

潇湘沐 2019-03-13 18:15:26
按我的理解,当一个线程需要获取的锁被另一个线程占用时,将进入阻塞态。但实际好像不是这样的,下面是我的代码。在run方法中会调用MyBlock的isBlocked方法,该方法添加了synchronized限定。在main方法中创建两个线程:t1和t2,t1运行后,由于isBlocked方法运行需要一定时间,t2应该进入阻塞态。但我调用getState方法得到的是Runnable,不是Blocked。这是为啥呢? public class TestThread implements Runnable {     private String mThreadName = null;     private MyLock mLock = null;          public TestThread(String name, MyLock l){         mThreadName = name;         mLock = l;     }          @Override     public void run() {         // TODO Auto-generated method stub         subTask();     }          private void subTask()     {         System.out.println(mThreadName + "START!");         mLock.isLocked();         System.out.println(mThreadName + "END!");     }          /**      * @param args      */     public static void main(String[] args) {         // TODO Auto-generated method stub         MyLock lock = new MyLock();                  TestThread r1 = new TestThread("A", lock);         Thread t1 = new Thread(r1);         t1.start();                  TestThread r2 = new TestThread("B", lock);         Thread t2 = new Thread(r2);         t2.start();         System.out.println(t2.getState());         //t2.interrupt();         System.out.println(t2.getState());                  System.out.println("MAIN END!");     }          public static class MyLock{         private ReentrantLock mLock = new ReentrantLock();              public synchronized void isLocked(){             System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@");             for (int i = 0; i < 10000; i ++){                 System.out.print("," + i);             }             System.out.println("#############################");         }     } }
查看完整描述

5 回答

?
牛魔王的故事

TA贡献1830条经验 获得超3个赞

线程运行的不确定性 导致你不一定能看到 锁现象,阻塞现象。


查看完整回答
反对 回复 2019-04-26
?
茅侃侃

TA贡献1842条经验 获得超21个赞

private ReentrantLock mLock = new ReentrantLock();

还可以用mLock通过trylock和lock去在临界区枷锁测试。


查看完整回答
反对 回复 2019-04-26
?
白板的微信

TA贡献1883条经验 获得超3个赞

package iteye;

public class TestThread implements Runnable {
private final String mThreadName;
private final MyLock mLock;

public TestThread(String name, MyLock l) {
    mThreadName = name;
    mLock = l;
}

public void run() {
    System.out.println(mThreadName + " START!");
    mLock.lock();
    System.out.println(mThreadName + " END!");
}

/**
 * @param args
 */
public static void main(String[] args) {
    MyLock lock = new MyLock();

    TestThread r1 = new TestThread("A", lock);
    Thread t1 = new Thread(r1);
    t1.start();
    // 确保t1先进入run方法
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
    }

    TestThread r2 = new TestThread("B", lock);
    Thread t2 = new Thread(r2);
    t2.start();
    // 确保t2进入run方法
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
    }
    // 只有t1正在执行lock方法中,而t2也进入run方法等待执行lock方法时,t2的状态才是BLOCKED
    System.out.println(t2.getState());
    System.out.println("MAIN END!");

}

public static class MyLock {

    public synchronized void lock() {
        try {
            Thread.sleep(7000);//模拟线程的执行时间比较长
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

}


查看完整回答
反对 回复 2019-04-26
  • 5 回答
  • 0 关注
  • 1136 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信