Java 并发框架的提交方法
submit method of Java concurrent framework
Java 并发框架的新提交方法。想知道线程是在我调用 submit 还是调用 get 时执行的?研究了Oracle官方文档,但找不到太多信息。谢谢
我指的是下面的示例,
http://www.vogella.com/tutorials/JavaConcurrency/article.html
package de.vogella.concurrency.callables;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableFutures {
private static final int NTHREDS = 10;
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);
List<Future<Long>> list = new ArrayList<Future<Long>>();
for (int i = 0; i < 20000; i++) {
Callable<Long> worker = new MyCallable();
Future<Long> submit = executor.submit(worker);
list.add(submit);
}
long sum = 0;
System.out.println(list.size());
// now retrieve the result
for (Future<Long> future : list) {
try {
sum += future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
System.out.println(sum);
executor.shutdown();
}
}
不,调用提交不执行任务。并且调用 get 不执行任务。任务在属于执行者线程池的线程中异步处理。
调用提交方法将任务交给线程池。任务排队直到池中的线程之一空闲。然后池将任务分配给调用代码的工作线程。
当您调用 Future.get 时,工作人员已完成处理您的任务,工作人员当前正在处理您的任务,或者任务仍在排队等待工作人员可用。如果您的任务已完成,那么未来 returns 从 Callable 任务返回的值,否则调用未来的 get 方法会导致您的主线程阻塞,直到任务完成。
方法 submit()
将您的任务提交到线程池,而 Future#get()
让当前线程等待,直到任务已被池中的一个线程执行,无论失败与否。
Java 并发框架的新提交方法。想知道线程是在我调用 submit 还是调用 get 时执行的?研究了Oracle官方文档,但找不到太多信息。谢谢
我指的是下面的示例,
http://www.vogella.com/tutorials/JavaConcurrency/article.html
package de.vogella.concurrency.callables;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableFutures {
private static final int NTHREDS = 10;
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);
List<Future<Long>> list = new ArrayList<Future<Long>>();
for (int i = 0; i < 20000; i++) {
Callable<Long> worker = new MyCallable();
Future<Long> submit = executor.submit(worker);
list.add(submit);
}
long sum = 0;
System.out.println(list.size());
// now retrieve the result
for (Future<Long> future : list) {
try {
sum += future.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
System.out.println(sum);
executor.shutdown();
}
}
不,调用提交不执行任务。并且调用 get 不执行任务。任务在属于执行者线程池的线程中异步处理。
调用提交方法将任务交给线程池。任务排队直到池中的线程之一空闲。然后池将任务分配给调用代码的工作线程。
当您调用 Future.get 时,工作人员已完成处理您的任务,工作人员当前正在处理您的任务,或者任务仍在排队等待工作人员可用。如果您的任务已完成,那么未来 returns 从 Callable 任务返回的值,否则调用未来的 get 方法会导致您的主线程阻塞,直到任务完成。
方法 submit()
将您的任务提交到线程池,而 Future#get()
让当前线程等待,直到任务已被池中的一个线程执行,无论失败与否。