Подтвердить что ты не робот

Дамп потока Java: разница между "ожиданием блокировки" и "парковкой для ожидания"?

В дампе потока Java вы можете видеть блокировки, упомянутые в трассировке стека.
Кажется, есть три вида информации:

1

- locked <0x00002aab329f7fa0> (a java.io.BufferedInputStream)

2:

- waiting to lock <0x00002aaaf4ff6fa0> (a org.alfresco.repo.lock.LockServiceImpl)

3:

- parking to wait for  <0x00002aaafbf70bb8> (a java.util.concurrent.SynchronousQueue$TransferStack)
  • 1: поток получил блокировку объекта 0x00002aab329f7fa0.
  • 2 & 3: Предположим, что поток ожидает, что блокировка указанного объекта станет доступной...
    но в чем разница 2 и 3?
4b9b3361

ОТВЕТЫ

Ответ 1

Вы получите "ожидание блокировки" в дампе потока при использовании встроенных блокировок и "парковки для ожидания" при использовании блокировок из java.util.concurrent. Рассмотрим следующий пример:

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

public class LockTest {

    final Lock lock = new ReentrantLock(true);

    synchronized void intrinsicLock() {
        Thread th = new Thread(new Runnable() {
            public void run() {
                intrinsicLock();
            }
        }, "My thread");
        th.start();
        try {
            th.join();
        } catch (InterruptedException e) {
        }
    }

    void reentrantLock() {
        lock.lock();
        Thread th = new Thread(new Runnable() {
            public void run() {
                reentrantLock();
            }
        }, "My thread");
        th.start();
        try {
            th.join();
        } catch (InterruptedException e) {
        }
        lock.unlock();
    }


    public static void main(String[] args) {
        LockTest lockTest = new LockTest();
        lockTest.intrinsicLock();
        //lockTest.reentrantLock();
    }

}

С lockTest.intrinsicLock() вы получите следующий дамп потока:

"My thread" prio=10 tid=0x00007fffec015800 nid=0x1775 waiting for monitor entry [0x00007ffff15e5000]
   java.lang.Thread.State: BLOCKED (on object monitor)
    at LockTest.intrinsicLock(LockTest.java:9)
    - waiting to lock <0x00000007d6a33b10> (a LockTest)
    at LockTest$1.run(LockTest.java:11)
    at java.lang.Thread.run(Thread.java:662)

пока lockTest.reentrantLock() произведет:

"My thread" prio=10 tid=0x00007fffec082800 nid=0x17e8 waiting on condition [0x00007ffff14eb000]
   java.lang.Thread.State: WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00000007d6a33d30> (a java.util.concurrent.locks.ReentrantLock$FairSync)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
    at java.util.concurrent.locks.ReentrantLock$FairSync.lock(ReentrantLock.java:201)
    at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
    at LockTest.reentrantLock(LockTest.java:22)
    at LockTest$2.run(LockTest.java:25)
    at java.lang.Thread.run(Thread.java:662)

Ответ 2

По-моему, пакет java.util.concurrent почти использует метод LockSupport.park() для блокировки потока, например CountDownLatch, ReentrantLock, которые принадлежат абстрактно-синхронизированной структуре. Таким образом, третий сценарий в ваших вопросах означает, что ваш код, наконец, вызывает метод LockSupport.park(), поскольку вы используете параллельный класс в пакете java.util.concurrent, второй сценарий означает, что вы явно используете синхронную работу с ключевыми словами и метод wait().