ParallelPromisesTests.java

	@Test
	public void testParallelPromises() throws InterruptedException {
		Environment environment = new Environment();
		final AtomicBoolean first = new AtomicBoolean(true);
		for (int i = 0; i < 10; i++) {
			final Promise<String> promise = Promises.task(environment, () -> {
						if (!first.getAndSet(false)) {
							try {
								Thread.sleep(1000);
							}
							catch (InterruptedException e) {
								e.printStackTrace();
							}
						}
						return "foo";
					}
			);
			String result = promise.await(10, TimeUnit.SECONDS);
			System.out.println(result);
			assertNotNull(result);
		}
	}