|
| 1 | +package com.javarush.test.level30.lesson04.home01; |
| 2 | + |
| 3 | +import java.util.concurrent.LinkedTransferQueue; |
| 4 | +import java.util.concurrent.TransferQueue; |
| 5 | + |
| 6 | +/* Экономим время |
| 7 | +1. Создайте Producer и Consumer (См. комментарий к методу main) |
| 8 | +2. Создайте методы toString, equals и hashCode в классе ShareItem. Для этого в теле класса ShareItem выполни: |
| 9 | +2.1. Alt+Enter -> toString() -> Enter |
| 10 | +2.2. Alt+Enter -> equals() and hashCode() -> click all 'Next'-s |
| 11 | +3. В Producer и Consumer реализуйте метод run так, чтобы вызов метода interrupt прерывал работу consumer и producer трэдов |
| 12 | +
|
| 13 | +4. Реализация метода run для Producer: |
| 14 | +4.1. Используя метод offer добавить в очередь 9 ShareItem-ов с такими параметрами: ("ShareItem-N", N), где N - номер элемента от 1 до 9 |
| 15 | +4.2. Перед каждым добавлением вывести фразу "Элемент 'ShareItem-N' добавлен". Используйте System.out.format |
| 16 | +4.3. Усыпить трэд на 0.1 секунды |
| 17 | +4.4. Если у очереди есть Consumer, не занятый работой, то вывести фразу "Consumer в ожидании!". |
| 18 | +Просмотрите методы интерфейса TransferQueue, там есть нужный метод. |
| 19 | +
|
| 20 | +5. Реализация метода run для Consumer: |
| 21 | +5.1. Усыпить трэд на 0.5 секунды |
| 22 | +5.2. В бесконечном цикле заберите элемент из очереди методом take и выведите в консоль "Processing item.toString()". |
| 23 | +
|
| 24 | +6. Сверьте вывод с файлом output.txt |
| 25 | +7. Стек-трейс не выводите в консоль |
| 26 | +*/ |
| 27 | +public class Solution { |
| 28 | + /* |
| 29 | + 1. Создайте класс Producer. Для этого на красном имени класса нажмите Alt+Enter -> Create Class ... |
| 30 | + 2. Станьте на имени аргумента в конструкторе (queue) и нажмите Alt+Enter -> Create Field for Parameter 'queue' -> Enter -> Enter |
| 31 | + 3. Станьте на подчеркнутой строке - описании класса. Далее Alt+Enter -> Implement Methods -> Enter |
| 32 | + 4. Проделайте п.1-3 для класса Consumer |
| 33 | + */ |
| 34 | + |
| 35 | + public static void main(String[] args) throws InterruptedException { |
| 36 | + TransferQueue<ShareItem> queue = new LinkedTransferQueue<>(); |
| 37 | + |
| 38 | + Thread producer = new Thread(new Producer(queue)); |
| 39 | + Thread consumer = new Thread(new Consumer(queue)); |
| 40 | + producer.start(); |
| 41 | + consumer.start(); |
| 42 | + |
| 43 | + Thread.sleep(1500); |
| 44 | + |
| 45 | + producer.interrupt(); |
| 46 | + consumer.interrupt(); |
| 47 | + } |
| 48 | + |
| 49 | +} |
0 commit comments