Add a lambda implementation

src/main/java/io/herrmann/generator/ConsumingGenerator.java

@@ -0,0 +1,6 @@
+package io.herrmann.generator;
+
+@FunctionalInterface
+public interface ConsumingGenerator<T> {
+	void generate(Generator<T> generator) throws InterruptedException;
+}

src/main/java/io/herrmann/generator/LambdaGenerator.java

@@ -0,0 +1,18 @@
+package io.herrmann.generator;
+
+public class LambdaGenerator<T> extends Generator<T> {
+	private ConsumingGenerator<T> generator;
+
+	public LambdaGenerator(ConsumingGenerator<T> generator) {
+		this.generator = generator;
+	}
+
+	public LambdaGenerator(final ValueGenerator<T> generator) {
+		this(g -> generator.generate());
+	}
+
+	@Override
+	protected void run() throws InterruptedException {
+		this.generator.generate(this);
+	}
+}

src/main/java/io/herrmann/generator/ValueGenerator.java

@@ -0,0 +1,6 @@
+package io.herrmann.generator;
+
+@FunctionalInterface
+public interface ValueGenerator {
+	void generate() throws InterruptedException;
+}