Separate Thread Input

import std.stdio;
import queue : Queue;
import core.thread : Thread;

class ThreadInput : Thread {
	private Queue!string queue;

	this(Queue!string queue) {
		super(&run);
		this.queue = queue;
	}

	private void run() {
		while (true) {
			queue.put(readln);
		}
	}
}

void main() {
	Queue!string inputQueue = new Queue!string;
	ThreadInput threadInput = new ThreadInput(inputQueue);
	threadInput.start;

	while (true) {
		foreach (string value; inputQueue) {
			writeln(value);
		}
	}
}