Межпотоковая связь между производителями и потребителями? - PullRequest
Новая
       45

Межпотоковая связь между производителями и потребителями?

0 голосов
/ 02 октября 2019

Я пытаюсь научиться взаимодействовать между потоками, где я использую BlockingQueue.

Я написал продюсер, который сгенерирует TaskId и вставит его в BlockingQueue.

Теперь у меня есть 2 потока потребителей (имя "1" и "0"). Если taskId нечетный, он используется потоком «1», иначе «2». 

@Override
    public void run() {
        while (true) {

                while (queue.peek() != null && !name.equals(String.valueOf(queue.peek().intValue() % 2 ))) {

                try {
                    System.out.println(name + ",consumed," + queue.take());
                } catch (InterruptedException e) {
                    e.printStackTrace();

                }
            }
        }
    }

Как я могу сделать эту проверку и здесь?

1 Ответ

0 голосов
/ 02 октября 2019

С одной стороны, я думаю, могут быть и другие лучшие способы: 

@Override
    public void run() {
        String name = Thread.currentThread().getName();
        while (true) {

            while (queue.peek() == null) {
                //some sleep time
            }

            synchronized (lock) {
                while (queue.peek() != null && !name.equals(String.valueOf(queue.peek().intValue() % 2 ))) {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if(queue.peek() != null) {
                    try {
                        System.out.println(name + ",consumed," + queue.take());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                lock.notify();
            }
        }
    }

Другой способ: иметь другую блокировку, которая будет уведомлена потоком производителя при добавлении элемента в очередь. 

@Override
    public void run() {
        String name = Thread.currentThread().getName();
        while (true) {

            synchronized (anotherLock) {
                while (queue.peek() == null) {
                    anotherLock.wait();
                }
            }

            synchronized (lock) {
                while (queue.peek() != null && !name.equals(String.valueOf(queue.peek().intValue() % 2 ))) {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if(queue.peek() != null) {
                    try {
                        System.out.println(name + ",consumed," + queue.take());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                lock.notify();
            }
        }
    }
...