Все выводит как надо и без deadlock-а

Вопрос по задаче

Java Multithreading, 7 уровень, 6 лекция

Решен

Пишет, что не выполнено условие 1: Метод isLockOrderNormal должен возвращать true в случае, если синхронизация в методе someMethodWithSynchronizedBlocks происходит сначала по объекту o1, а потом по o2 Но вывод верный:

true
java.lang.Object@2baa6ebd java.lang.Object@256d95b8

Реализуй логику метода isLockOrderNormal, который должен определять:
соответствует ли порядок synchronized блоков в методе someMethodWithSynchronizedBlocks - порядку передаваемых в него аргументов.
В случае, если сначала происходит синхронизация по o1, а потом по o2, метод должен вернуть true.
Если наоборот - false.

Требования:

Метод isLockOrderNormal должен возвращать true в случае, если синхронизация в методе someMethodWithSynchronizedBlocks происходит сначала по объекту o1, а потом по o2.
Метод isLockOrderNormal должен возвращать false в случае, если синхронизация в методе someMethodWithSynchronizedBlocks происходит сначала по объекту o2, а потом по o1.
Метод isLockOrderNormal НЕ должен быть приватным.
Класс Solution НЕ должен быть объявлен с модификатором final.

package com.javarush.task.task27.task2707; import java.util.concurrent.atomic.AtomicBoolean; /* Определяем порядок захвата монитора */ public class Solution { public void someMethodWithSynchronizedBlocks(Object obj1, Object obj2) { synchronized (obj1) { synchronized (obj2) { System.out.println(obj1 + " " + obj2); } } } public static boolean isLockOrderNormal(final Solution solution, final Object o1, final Object o2) throws InterruptedException { AtomicBoolean status = new AtomicBoolean(false); synchronized (o1) { Thread t1 = new Thread(() -> solution.someMethodWithSynchronizedBlocks(o1, o2)); t1.start(); while (t1.getState() != Thread.State.BLOCKED); Thread t2 = new Thread(() -> { synchronized (o2) { status.set(true); synchronized (o1) { } } }); t2.start(); while (t2.getState()!= Thread.State.BLOCKED); return status.get(); } } public static void main(String[] args) throws Exception { final Solution solution = new Solution(); final Object o1 = new Object(); final Object o2 = new Object(); System.out.println(isLockOrderNormal(solution, o1, o2)); } }

Комментарии (4)

популярные
новые
старые

Для того, чтобы оставить комментарий Вы должны авторизоваться

Grock

Уровень 41

17 сентября, 16:21

решение

Решилось в итоге с 9-й попытки так: 1. Создаем 1-ю нить и блок, синхронизированный по o1, потом ждем 100 мс и создаем блок, синхронизированный по o2. 2. Создаем 2-ю нить, а в ней планируем запуск нашего метода. 3. Делаем обе нити демонами. 4. Запускаем сначала 1-ю нить, потом 2-ю. 5. В основном потоке ждем 200 мс. 6. Возвращаем: вторая нить не заблокирована. Т.е. решение через deadlock. Хотя решение, которое я опубликовал в самом начала оптимальное, поскольку: - не создает deadlocka; - не заставляет нити ждать или спать.

Grock

Уровень 41

17 сентября, 15:37

В идее также работает, но валидацию не проходит по 1-му пункту.

public static boolean isLockOrderNormal(final Solution solution, final Object o1, final Object o2) throws InterruptedException {
    AtomicBoolean status = new AtomicBoolean(false);
    Thread t1 = new Thread(() -> solution.someMethodWithSynchronizedBlocks(o2, o1));
    Thread t2 = new Thread(() -> { synchronized (o2){ status.set(true);synchronized (o1){}}});
    new Thread(() -> {
        synchronized (o1) {
            t1.setDaemon(true);
            t1.start();
            t2.setDaemon(true);
            t2.start();
            try { Thread.sleep(10);
            } catch (InterruptedException ignored) { } } }).start();
    Thread.sleep(5);
    return status.get();
}

Grock

Уровень 41

17 сентября, 15:48

То же самое:

public static boolean isLockOrderNormal(final Solution solution, final Object o1, final Object o2) throws InterruptedException {
    AtomicBoolean status = new AtomicBoolean(false);
    Thread t1 = new Thread(() -> solution.someMethodWithSynchronizedBlocks(o1, o2));
    Thread t2 = new Thread(() -> { synchronized (o2){ status.set(true);synchronized (o1){}}});
    Thread t3 =new Thread(() -> {
        synchronized (o1) {
            t1.start();
            t2.start();
            try { Thread.sleep(100);
            } catch (InterruptedException ignored) { } } });
            t3.setDaemon(true);
            t3.start();
    Thread.currentThread().join(10);
    return status.get();
}

Grock

Уровень 41

17 сентября, 14:32

В идее работает, но валидацию не проходит по причине якобы бесконечного цикла:

public static boolean isLockOrderNormal(final Solution solution, final Object o1, final Object o2) throws InterruptedException {
    AtomicBoolean status = new AtomicBoolean(false);

    Thread t1 = new Thread(() -> { synchronized (o2) { status.set(true); { synchronized (o1) { } } } });

    Thread t2 = new Thread(() -> solution.someMethodWithSynchronizedBlocks(o1, o2));

    new Thread(() -> { synchronized (o1) { t2.start();
            try {
                Thread.sleep(1);
            } catch (InterruptedException ignored) { } } }).start();

    while (t2.getState() != Thread.State.BLOCKED);

    t1.start();

    while (t1.getState() != Thread.State.BLOCKED);

    return status.get();
}