import java.util.stream.IntStream;

public class Example {

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

        ExchangerReuse<String> exchanger = new ExchangerReuse<>();
        IntStream.range(0, 10).forEach(i -> {
            new Thread(() -> {
                try {
                    System.out.println("thread "+i + " received from " + exchanger.exchange("thread "+i));
                } catch (InterruptedException e) {
                    throw new AssertionError(e);
                }
            }).start();
        });
    }
}