This commit is contained in:
Grzegorz Piwowarek 2017-11-13 18:10:14 +01:00 committed by GitHub
parent 25fe85d849
commit 00282dd43e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -1,24 +1,21 @@
package com.baeldung.concurrent.runnable; package com.baeldung.concurrent.runnable;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import org.apache.commons.lang3.RandomUtils; import org.apache.commons.lang3.RandomUtils;
import org.junit.After;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
public class RunnableVsThreadTest { public class RunnableVsThreadLiveTest {
private static Logger log = private static Logger log =
LoggerFactory.getLogger(RunnableVsThreadTest.class); LoggerFactory.getLogger(RunnableVsThreadLiveTest.class);
private static ExecutorService executorService; private static ExecutorService executorService;
@ -77,9 +74,7 @@ public class RunnableVsThreadTest {
public void givenACallableAsLambda_whenSubmitToES_thenResult() public void givenACallableAsLambda_whenSubmitToES_thenResult()
throws Exception { throws Exception {
Future<Integer> future = executorService.submit(() -> { Future<Integer> future = executorService.submit(() -> RandomUtils.nextInt(0, 100));
return RandomUtils.nextInt(0, 100);
});
log.info("Result from callable: {}", future.get()); log.info("Result from callable: {}", future.get());
} }
@ -99,7 +94,7 @@ class SimpleThread extends Thread{
private String message; private String message;
public SimpleThread(String message) { SimpleThread(String message) {
this.message = message; this.message = message;
} }
@ -116,7 +111,7 @@ class SimpleRunnable implements Runnable {
private String message; private String message;
public SimpleRunnable(String message) { SimpleRunnable(String message) {
this.message = message; this.message = message;
} }