package com.example;

import java.io.PrintStream;
import java.util.Date;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

// BlockingQueue へメッセージを格納し続けるタスク
class SenderTask implements Runnable {
    private final String name;
    private final BlockingQueue<Date> queue;
    private final PrintStream out;
    public SenderTask(String name, BlockingQueue<Date> queue, PrintStream out) {
        this.name = name;
        this.queue = queue;
        this.out = out;
    }
    @Override
    public void run() {
        try {
            while (true) {
                queue.put(new Date());
                TimeUnit.SECONDS.sleep(1);
            }
        } catch (InterruptedException e) {
            out.printf("%s interrupted: %s", name, e.getMessage());
        }
    }
}

// BlockingQueue からメッセージを取得し続けるタスク
class ReceiverTask implements Runnable {
    private final String name;
    private final BlockingQueue<Date> queue;
    private final PrintStream out;
    public ReceiverTask(String name, BlockingQueue<Date> queue, PrintStream out) {
        this.name = name;
        this.queue = queue;
        this.out = out;
    }
    @Override
    public void run() {
        try {
            while (true) {
                process(queue.take());
            }
        } catch (InterruptedException e) {
            out.printf("%s interrupted: %s", name, e.getMessage());
        }
    }
    private void process(Date date) {
        out.printf("%s: %tc\n", name, date);
    }
}

public class Main {
    public static void main(String[] args) {
        BlockingQueue<Date> queue = new LinkedBlockingQueue<>(5);

        // 送信スレッドと受信スレッドを開始
        Thread sender = new Thread(new SenderTask("Sender", queue, System.out));
        new Thread(new ReceiverTask("Recv1", queue, System.out)).start();
        new Thread(new ReceiverTask("Recv2", queue, System.out)).start();
        new Thread(new ReceiverTask("Recv3", queue, System.out)).start();
        sender.start();

        // 動かし続ける
        try {
            sender.join();
        } catch (InterruptedException ignore) {}
    }
}