javarush level30.lesson04.home01

home01_Consumer.java

package com.javarush.test.level30.lesson04.home01;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.TransferQueue;

/**
 * Created by FarAway on 10.03.2016.
 */
public class Consumer implements Runnable {
    private TransferQueue<ShareItem> queue;

    public Consumer(TransferQueue<ShareItem> queue) {this.queue = queue;}

    @Override
    public void run() {
        try {
            TimeUnit.MILLISECONDS.sleep(500);

            while (!Thread.currentThread().isInterrupted()) {
                System.out.println("Processing " + queue.take().toString());
            }
        } catch (InterruptedException e) {}
    }
}

home01_output.txt

Элемент 'ShareItem-1' добавлен
Элемент 'ShareItem-2' добавлен
Элемент 'ShareItem-3' добавлен
Элемент 'ShareItem-4' добавлен
Элемент 'ShareItem-5' добавлен
Processing ShareItem{description='ShareItem-1', itemId=1}
Processing ShareItem{description='ShareItem-2', itemId=2}
Processing ShareItem{description='ShareItem-3', itemId=3}
Processing ShareItem{description='ShareItem-4', itemId=4}
Processing ShareItem{description='ShareItem-5', itemId=5}
Consumer в ожидании!
Элемент 'ShareItem-6' добавлен
Processing ShareItem{description='ShareItem-6', itemId=6}
Consumer в ожидании!
Элемент 'ShareItem-7' добавлен
Processing ShareItem{description='ShareItem-7', itemId=7}
Consumer в ожидании!
Элемент 'ShareItem-8' добавлен
Processing ShareItem{description='ShareItem-8', itemId=8}
Consumer в ожидании!
Элемент 'ShareItem-9' добавлен
Processing ShareItem{description='ShareItem-9', itemId=9}
Consumer в ожидании!

home01_Producer.java

package com.javarush.test.level30.lesson04.home01;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.TransferQueue;

/**
 * Created by FarAway on 10.03.2016.
 */
public class Producer implements Runnable {
    private TransferQueue<ShareItem> queue;

    public Producer(TransferQueue<ShareItem> queue) {this.queue = queue;}

    @Override
    public void run() {
        //)
        try {
        for (int i = 1; i <= 9; i++)
            if (!Thread.currentThread().isInterrupted()) {
                System.out.format("Элемент 'ShareItem-%d' добавлен%n", i);
                queue.offer(new ShareItem("ShareItem-" + i, i));

                TimeUnit.MILLISECONDS.sleep(100);

                if (queue.hasWaitingConsumer())
                    System.out.println("Consumer в ожидании!");
            }
        } catch (InterruptedException e) {
            return;
        }
    }
}

home01_ShareItem.java

package com.javarush.test.level30.lesson04.home01;

import java.util.Objects;

//this class shows how to call other constructors using 'this'
public class ShareItem {
    public String description;
    public int itemId;

    public ShareItem() {
        this("Test Item", 0);
    }

    public ShareItem(String description) {
        this(description, 0);
    }

    public ShareItem(int itemId) {
        this("Test Item", itemId);
    }

    public ShareItem(String description, int itemId) {
        this.description = description;
        this.itemId = itemId;
    }

    public String getDescription() {
        return description;
    }

    public int getItemId() {
        return itemId;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        ShareItem shareItem = (ShareItem) o;
        return itemId == shareItem.itemId &&
                Objects.equals(description, shareItem.description);
    }

    @Override
    public int hashCode() {
        return Objects.hash(description, itemId);
    }

    @Override
    public String toString() {
        return "ShareItem{" +
                "description='" + description + '\'' +
                ", itemId=" + itemId +
                '}';
    }
}

home01_Solution.java

package com.javarush.test.level30.lesson04.home01;

import java.util.concurrent.LinkedTransferQueue;
import java.util.concurrent.TransferQueue;

/* Экономим время
1. Создайте Producer и Consumer (См. комментарий к методу main)
2. Создайте методы toString, equals и hashCode в классе ShareItem. Для этого в теле класса ShareItem выполни:
2.1. Alt+Enter -> toString() -> Enter
2.2. Alt+Enter -> equals() and hashCode() -> click all 'Next'-s
3. В Producer и Consumer реализуйте метод run так, чтобы вызов метода interrupt прерывал работу consumer и producer трэдов

4. Реализация метода run для Producer:
4.1. Используя метод offer добавить в очередь 9 ShareItem-ов с такими параметрами: ("ShareItem-N", N), где N - номер элемента от 1 до 9
4.2. Перед каждым добавлением вывести фразу "Элемент 'ShareItem-N' добавлен". Используйте System.out.format
4.3. Усыпить трэд на 0.1 секунды
4.4. Если у очереди есть Consumer, не занятый работой, то вывести фразу "Consumer в ожидании!".
Просмотрите методы интерфейса TransferQueue, там есть нужный метод.

5. Реализация метода run для Consumer:
5.1. Усыпить трэд на 0.5 секунды
5.2. В бесконечном цикле заберите элемент из очереди методом take и выведите в консоль "Processing item.toString()".

6. Сверьте вывод с файлом output.txt
7. Стек-трейс не выводите в консоль
*/
public class Solution {
    /*
    1. Создайте класс Producer. Для этого на красном имени класса нажмите Alt+Enter -> Create Class ...
    2. Станьте на имени аргумента в конструкторе (queue) и нажмите Alt+Enter -> Create Field for Parameter 'queue' -> Enter -> Enter
    3. Станьте на подчеркнутой строке - описании класса. Далее Alt+Enter -> Implement Methods -> Enter
    4. Проделайте п.1-3 для класса Consumer
     */

    public static void main(String[] args) throws InterruptedException {
        TransferQueue<ShareItem> queue = new LinkedTransferQueue<>();

        Thread producer = new Thread(new Producer(queue));
        Thread consumer = new Thread(new Consumer(queue));
        producer.start();
        consumer.start();

        Thread.sleep(1500);

        producer.interrupt();
        consumer.interrupt();
    }

}