ReentrantLock не показывает ожидаемый результат - PullRequest
Новая
       46

ReentrantLock не показывает ожидаемый результат

0 голосов
/ 28 апреля 2018

Где проблема? ReentrantLock не показывает ожидаемый результат. Два потока выполняются одновременно, а не ожидают один поток. 

class MyThread2 extends Thread{
    String name;
    ReentrantLock reentrantLock = new ReentrantLock();
    MyThread2(String name){
        this.name = name;
    }
    public void run(){
        do {
            try {
                if (reentrantLock.tryLock(20,TimeUnit.MILLISECONDS)){
                    System.out.println("executing : "+ name);
                    Thread.sleep(500);
                    reentrantLock.unlock();
                    break;
                }else {
                    System.out.println("waiting "+ name);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }while (true);
    }
}

public class LockDemo2{
    public static void main(String[] args) {
        new MyThread2("Thread - 1").start();
        new MyThread2("Thread - 2").start();
    }
}

Выход: 

executing : Thread - 1
executing : Thread - 2

Ответы [ 2 ]

0 голосов
/ 28 апреля 2018

Вы используете два разных ReentrantLock в двух разных потоках. @ user6690200 Решение правильно использовать ту же блокировку через конструктор.

Другое решение - вы можете изменить ReentrantLock на:

private static final ReentrantLock reentrantLock = new ReentrantLock();

Так что каждый экземпляр другого потока всегда будет совместно использовать только один объект вашего ReentrantLock.

0 голосов
/ 28 апреля 2018

Вы должны использовать один и тот же ReentrantLock в разных потоках, вместо этого создавая разные блокировки.

Измените конструктор на это: 

ReentrantLock reentrantLock;
MyThread2(String name, ReentrantLock lock){
    this.name = name;
    this.reentrantLock = lock;
}

И передайте им тот же замок: 

ReentrantLock lock = new ReentrantLock();
new MyThread2("Thread - 1", lock).start();
new MyThread2("Thread - 2", lock).start();
...