猿问

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

按我的理解,当一个线程需要获取的锁被另一个线程占用时,将进入阻塞态。但实际好像不是这样的,下面是我的代码。

在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("#############################");
        }
    }

}


潇湘沐
浏览 1162回答 5
5回答

牛魔王的故事

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

茅侃侃

private ReentrantLock mLock = new ReentrantLock();还可以用mLock通过trylock和lock去在临界区枷锁测试。

白板的微信

package iteye;public class TestThread implements Runnable {private final String mThreadName;private final MyLock mLock;public&nbsp;TestThread(String&nbsp;name,&nbsp;MyLock&nbsp;l)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;mThreadName&nbsp;=&nbsp;name; &nbsp;&nbsp;&nbsp;&nbsp;mLock&nbsp;=&nbsp;l; } public&nbsp;void&nbsp;run()&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;System.out.println(mThreadName&nbsp;+&nbsp;"&nbsp;START!"); &nbsp;&nbsp;&nbsp;&nbsp;mLock.lock(); &nbsp;&nbsp;&nbsp;&nbsp;System.out.println(mThreadName&nbsp;+&nbsp;"&nbsp;END!"); } /** &nbsp;*&nbsp;@param&nbsp;args &nbsp;*/ public&nbsp;static&nbsp;void&nbsp;main(String[]&nbsp;args)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;MyLock&nbsp;lock&nbsp;=&nbsp;new&nbsp;MyLock(); &nbsp;&nbsp;&nbsp;&nbsp;TestThread&nbsp;r1&nbsp;=&nbsp;new&nbsp;TestThread("A",&nbsp;lock); &nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;t1&nbsp;=&nbsp;new&nbsp;Thread(r1); &nbsp;&nbsp;&nbsp;&nbsp;t1.start(); &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;确保t1先进入run方法 &nbsp;&nbsp;&nbsp;&nbsp;try&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;catch&nbsp;(InterruptedException&nbsp;e)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;TestThread&nbsp;r2&nbsp;=&nbsp;new&nbsp;TestThread("B",&nbsp;lock); &nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;t2&nbsp;=&nbsp;new&nbsp;Thread(r2); &nbsp;&nbsp;&nbsp;&nbsp;t2.start(); &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;确保t2进入run方法 &nbsp;&nbsp;&nbsp;&nbsp;try&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;catch&nbsp;(InterruptedException&nbsp;e)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;只有t1正在执行lock方法中,而t2也进入run方法等待执行lock方法时,t2的状态才是BLOCKED &nbsp;&nbsp;&nbsp;&nbsp;System.out.println(t2.getState()); &nbsp;&nbsp;&nbsp;&nbsp;System.out.println("MAIN&nbsp;END!"); } public&nbsp;static&nbsp;class&nbsp;MyLock&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;synchronized&nbsp;void&nbsp;lock()&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.sleep(7000);//模拟线程的执行时间比较长 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;catch&nbsp;(InterruptedException&nbsp;e)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} }}
随时随地看视频慕课网APP

相关分类

Java
我要回答