使用 Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()) 时的潜在过载；

Question

我正在尝试使用多线程调用一个方法超过一百万次。所以我使用ExecutorService 并传递newFixedThreadPool 的动态值为：

Runtime.getRuntime().availableProcessors()

这会启动数千个线程，这会导致处理器负载过重吗？还是可以一起去？

ExecutorService service = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
ArrayList<Future<Boolean>> arrList = new ArrayList<Future<Boolean>>();
    for (final Vlaue val : List) {

        arrList.add(service.submit(new Callable() {
            @Override
            public Boolean call() throws Exception {

                Object obj = client.findObj(
                        val.getItem1(),val.getItem2());
                return obj.isValid();
            }
        }));

    }
    service.shutdown();
    for (Future future : arrList) {
        // at time future returns null here, not sure why?
        assertTrue("Invalid object" future.get());            
    }

Answer 1

这将创建Runtime.getRuntime().availableProcessors() 线程。

无论您向它提交多少任务，当它们可用时，它们只会排队并由这些线程处理。

也就是说，尽管您对Future 的使用似乎有点奇怪，但您所做的一切都很好。很可能有一种更有效的方法可以做到这一点，但你正在做的事情会奏效。