//Therefore let no man glory in men. For all things are yours; (1Cor 3:21)

package com.javarush.task.task26.task2610;

import java.util.concurrent.BlockingQueue;

public class Producer implements Runnable {

private BlockingQueue queue;

public Producer(BlockingQueue queue) {

this.queue = queue;

}

public void run() {

try {

int i = 0;

while (true) {

queue.put(String.valueOf(i++));

Thread.sleep(300);

}

} catch (InterruptedException e) {

System.out.println(String.format("[%s] thread was terminated", Thread.currentThread().getName()));

}

}

}

/*

Мир скучен для скучных людей

Разберись с BlockingQueue.

По образу и подобию класса Producer создай класс Consumer, который будет выводить данные из BlockingQueue в консоль.

Требования:

1. Класс Consumer должен быть создан в отдельном файле.

2. Класс Consumer должен реализовывать интерфейс Runnable.

3. Класс Consumer должен содержать приватное поле BlockingQueue queue.

4. Класс Consumer должен содержать конструктор с одним параметром, инициализирующий поле queue.

5. Метод run() класса Consumer должен постоянно выводить на экран значения из очереди.

package com.javarush.task.task26.task2610;

import java.util.concurrent.BlockingQueue;

public class Producer implements Runnable {

private BlockingQueue queue;

public Producer(BlockingQueue queue) {

this.queue = queue;

}

public void run() {

try {

int i = 0;

while (true) {

queue.put(String.valueOf(i++));

Thread.sleep(300);

}

} catch (InterruptedException e) {

System.out.println(String.format("[%s] thread was terminated", Thread.currentThread().getName()));

}

}

}

*/