// Again, "Praise the Lord, all you Gentiles! Let all the peoples praise him." (Romans 15:11)

package com.javarush.task.task16.task1628;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.atomic.AtomicInteger;

public class Solution {

public static volatile AtomicInteger countReadStrings = new AtomicInteger(0);

public static volatile BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

public static void main(String[] args) throws IOException {

//read count of strings

int count = Integer.parseInt(reader.readLine());

//init threads

ReaderThread consolReader1 = new ReaderThread();

ReaderThread consolReader2 = new ReaderThread();

ReaderThread consolReader3 = new ReaderThread();

consolReader1.start();

consolReader2.start();

consolReader3.start();

while (count > countReadStrings.get()) {

}

consolReader1.interrupt();

consolReader2.interrupt();

consolReader3.interrupt();

System.out.println("#1:" + consolReader1);

System.out.println("#2:" + consolReader2);

System.out.println("#3:" + consolReader3);

reader.close();

}

public static class ReaderThread extends Thread {

private List<String> result = new ArrayList<String>();

public void run() {

while (!isInterrupted()) { //add your code here - добавьте код тут

try {

if (reader.ready()) {

result.add(reader.readLine());

countReadStrings.incrementAndGet();

}

} catch (IOException e) {e.printStackTrace(); }

}

}

@Override

public String toString() {

return result.toString();

}

}

}

/*

Кто первый встал - того и тапки

1. Разберись, что делает программа.

1.1. Каждая нить должна читать с консоли слова. Используй готовый static BufferedReader reader.

1.2. Используй AtomicInteger countReadStrings, чтобы посчитать, сколько слов уже считано с консоли всеми нитями.

2. Реализуй логику метода run:

2.1. Пока нить не прервана (!isInterrupted) читай с консоли слова и добавляй их в поле List<String> result.

2.2. Используй countReadStrings для подсчета уже считанных с консоли слов.

Требования:

1. Метод run должен работать пока нить не прервана (!isInterrupted).

2. Метод run НЕ должен создавать свои InputStreamReader-ы или BufferedReader-ы.

3. Метод run должен считывать слова из reader и добавлять их в список result.

4. Метод run должен после каждого считывания увеличивать счетчик прочитанных строк countReadStrings на 1.

5. Программа должна выводить данные, считанные каждым потоком.

package com.javarush.task.task16.task1628;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.atomic.AtomicInteger;

public class Solution {

public static volatile AtomicInteger countReadStrings = new AtomicInteger(0);

public static volatile BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

public static void main(String[] args) throws IOException {

//read count of strings

int count = Integer.parseInt(reader.readLine());

//init threads

ReaderThread consolReader1 = new ReaderThread();

ReaderThread consolReader2 = new ReaderThread();

ReaderThread consolReader3 = new ReaderThread();

consolReader1.start();

consolReader2.start();

consolReader3.start();

while (count > countReadStrings.get()) {

}

consolReader1.interrupt();

consolReader2.interrupt();

consolReader3.interrupt();

System.out.println("#1:" + consolReader1);

System.out.println("#2:" + consolReader2);

System.out.println("#3:" + consolReader3);

reader.close();

}

public static class ReaderThread extends Thread {

private List<String> result = new ArrayList<String>();

public void run() {

//add your code here - добавьте код тут

}

@Override

public String toString() {

return result.toString();

}

}

}

*/