$search

ThreadPool.java

Go to the documentation of this file.

/*******************************************************************************
 * Copyright (c) 2012 Stefan Profanter. All rights reserved. This program and the accompanying
 * materials are made available under the terms of the GNU Public License v3.0 which accompanies
 * this distribution, and is available at http://www.gnu.org/licenses/gpl.html
 * 
 * Contributors: Stefan Profanter - initial API and implementation, Year: 2012
 ******************************************************************************/
package edu.tum.cs.ias.knowrob.utils;

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 ThreadPool {
        public static ExecutorService   pool;

        public static void executeInPool(List<Callable<Void>> threads) {

                if (pool == null)
                        init();

                try {
                        List<Future<Void>> futures = pool.invokeAll(threads);
                        for (Future<Void> f : futures) {
                                try {
                                        f.get(); // If called thread threw an exception, get will throw an
                                                                // ExecutionException
                                } catch (ExecutionException ex) {
                                        ex.getCause().printStackTrace(); // Print exceptions from called threads if
                                                                                                                // there were any
                                }
                        }
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
                threads.clear();
        }

        public static void init() {
                int threadNum = Runtime.getRuntime().availableProcessors() * 25;
                pool = Executors.newFixedThreadPool(threadNum);
        }
}

---

knowrob_common
Author(s): Moritz Tenorth
autogenerated on Tue Mar 5 12:14:08 2013