【发布时间】：2016-09-29 14:15:45
【问题描述】：
我是并发 Api 的新手，我只是制作程序并使用线性和并发方式对其进行测试。当我看到结果时，两个结果是相同的，执行时间没有区别。 代码如下：-
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class TestFuture {
private static final ExecutorService threadpool = Executors.newFixedThreadPool(3);
public static void main(String[] a) throws InterruptedException, ExecutionException{
TestFuture testFuture=new TestFuture();
testFuture.testFutureTask();
Date start=new Date();
System.out.println("Start time :: "+start);
TestLinear testLinear=new TestLinear();
for (int i = 0; i < 3; i++) {
if(i==0){
testLinear.getFirstOutput();
System.out.println("time to done by every thread :: one "+new Date());
}else if(i==1){
testLinear.getSecondOutput();
System.out.println("time to done by every thread :: second "+new Date());
}else if(i==2){
testLinear.getThirdOutput();
System.out.println("time to done by every thread :: third "+new Date());
}
}
Date end=new Date();
System.out.println("End time :: "+end);
System.out.println("Difference :: "+((end.getTime()-start.getTime())/1000));
}
public void testFutureTask() throws InterruptedException, ExecutionException{
Date start=new Date();
System.out.println("Future Start time :: "+start);
List<Future<String>> futureList=new ArrayList<Future<String>>();
CallableTest callableTest=null;
ResultClassTest resultClassTest=new ResultClassTest();
for (int i = 0; i < 3; i++) {
callableTest=new CallableTest();
callableTest.setThreadWork(""+i);
callableTest.setResultClassTest(resultClassTest);
Future<String> future=threadpool.submit(callableTest);
futureList.add(future);
}
threadpool.shutdown();
for (Future<String> future : futureList) {
System.out.println("time to done by every thread :: "+future.get()+" "+new Date());
}
System.out.println("result in Test future Result1 :: "+callableTest.getResultClassTest().getResult1());
System.out.println("result in Test future Result2 :: "+callableTest.getResultClassTest().getResult2());
System.out.println("result in Test future Result3 :: "+callableTest.getResultClassTest().getResult3());
Date end=new Date();
System.out.println("Future End time :: "+end);
System.out.println("Difference Future :: "+((end.getTime()-start.getTime())/1000));
}
}
import java.util.concurrent.Callable;
public class CallableTest implements Callable<String> {
private String threadWork;
private String result;
private ResultClassTest resultClassTest;
public String getThreadWork() {
return threadWork;
}
public void setThreadWork(String threadWork) {
this.threadWork = threadWork;
}
public String getResult() {
return result;
}
public void setResult(String result) {
this.result = result;
}
public ResultClassTest getResultClassTest() {
return resultClassTest;
}
public void setResultClassTest(ResultClassTest resultClassTest) {
this.resultClassTest = resultClassTest;
}
@Override
public String call() throws Exception {
if(threadWork!=null){
if(threadWork.equals("0")){
this.getResultClassTest().setResult1(this.getFirstOutput());
this.setResult("one");
}else if(threadWork.equals("1")){
this.getResultClassTest().setResult2(this.getSecondOutput());
this.setResult("two");
}else if(threadWork.equals("2")){
this.getResultClassTest().setResult3(this.getThirdOutput());
this.setResult("three");
}
}
return result;
}
private Long getThirdOutput() {
System.out.println("In Third");
Long a=0l;
for (long i = 400001; i < 600000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("three "+a);
return a;
}
private Long getSecondOutput() {
System.out.println("In Second");
Long a=0l;
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("two "+a);
return a;
}
private Long getFirstOutput() {
System.out.println("In First");
Long a=0l;
for (long i = 0; i < 200000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("one "+a);
return a;
}
}
public class ResultClassTest {
private Long result1;
private Long result2;
private Long result3;
public Long getResult1() {
return result1;
}
public void setResult1(Long result1) {
this.result1 = result1;
}
public Long getResult2() {
return result2;
}
public void setResult2(Long result2) {
this.result2 = result2;
}
public Long getResult3() {
return result3;
}
public void setResult3(Long result3) {
this.result3 = result3;
}
}
public class TestLinear {
public Long getThirdOutput() {
System.out.println("In Third");
Long a=0l;
for (long i = 400001; i < 600000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("three "+a);
return a;
}
public Long getSecondOutput() {
System.out.println("In Second");
Long a=0l;
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("two "+a);
return a;
}
public Long getFirstOutput() {
System.out.println("In First");
Long a=0l;
for (long i = 0; i < 200000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
for (long i = 200001; i < 400000000l; i++) {
a+=i;
}
System.out.println("one "+a);
return a;
}
}
这个测试包括四个类，分别是TestFuture（主类）、CallableTest（实现Callable接口）、ResultClassTest（Result Class for并发执行）和TestLinear（用于线性执行）。如果我做错了什么，请告诉我。
提前致谢。
【问题讨论】：
标签： java multithreading performance concurrency executorservice