0

次の非常に単純なコードが機能しない理由..スタックします..明示的なロックjava.util.concurrent.locks.ReentrantLock;とそのnewCondition()メソッドを使用しようとしています。

これが私のコードです：

    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.ReentrantLock;

    public class TheCondition implements Runnable {

        ReentrantLock lock = new ReentrantLock();
        Condition condition = lock.newCondition();

        static int variable = 2;

        public void incrementVariable() throws InterruptedException
        {
            lock.lock();
            try{    
               condition.await();
               for (int i = 0;i<100000;i++){
                         variable++;
               }
            }   
            finally
            {
               lock.unlock();
            }
        }


        public static void main (String []args) throws InterruptedException
        {
            TheCondition tc = new TheCondition();
            Thread t1 = new Thread(tc);
            t1.start();
            Thread.sleep(1000);
            tc.incrementVariable();
            t1.join();
            System.out.println(variable);
        }

        public void run()
        {
            for (int i = 0;i<100000;i++){
                variable++;     
            }
            System.out.println(variable);
            lock.lock();
            try{
                condition.signalAll();
            }
            finally{
                lock.unlock();
            }
        }
    }

私は同じロックをロックしているので、動作するはずです...代わりに、メインスレッドが呼び出されるとブロックされますincrementVariable()。なぜ、このようなことが起こるのでしょうか？前もって感謝します。

4

1 に答える 1

3

最初に を実行するrunと、数マイクロ秒で完了します。このメソッドは、どのスレッドもシグナルを送信signalAllしていないときに呼び出します。await次に、1 秒後incrementVariableにメイン スレッドを呼び出します。当然、メイン スレッドはawaitメソッドにハングアップし、シグナルを受信しません。

于 2013-07-23T16:17:19.410 に答える