Es gibt immer wieder Aufgaben, die sehr lange dauern und sehr gro\u00dfe Mengen an Daten verarbeiten m\u00fcssen. Dabei geht es meistens um Minuten oder gar Stunden, Tage …<\/p>\n
Diese sollten sinnvollerweise parallelisiert werden, um die Leistungs des Systems zu nutzen. Heutige Systeme sind sehr oft Mehrkern- bzw. Mehrprozessorsysteme. Auch ist das GHz-Rennen im Moment zu Ende und die Leistung steigt \u00fcber die Anzahl der Prozessoren bzw. Kerne.<\/p>\n
Das folgende Beispiel zeigt wie man unter Java Aufgaben parallel verarbeiten kann, ohne sich gro\u00df den Kopf um die Ausf\u00fchrung zerbrechen zu m\u00fcssen. Der ThreadPoolExecutor ist meiner Meinung nach eine sehr gute M\u00f6glichkeit Aufgaben zu parallelisieren, die Parallel ausgef\u00fchrt werden k\u00f6nnen. Der gro\u00dfe Vorteil ist, dass er Threads f\u00fcr das Abarbeiten am laufen h\u00e4lt. Das bedeutet bei neuen Aufgaben werden normalerweise keine Threads gestartet und somit entf\u00e4llt faktisch dieser Overhead. Threads im Pool werden nur beendet, wenn sie l\u00e4nger als der festgelegte Timeout nicht benutzt werden oder sie vom Programmierer explizit beendet werden.<\/p>\n
Nicht erschrecken. Das meiste davon sind Kommentare und Beispielcode.<\/p>\n
Ich wei\u00df – weniger Gelaber und her mit dem Code!<\/p>\n
[code]
\nimport java.util.concurrent.*;<\/p>\n
class MyThreadPoolExecutor
\n{
\n\t\/\/Parallel running Threads(Executor) on System
\n int corePoolSize = 2;<\/p>\n
\/\/Maximum Threads allowed in Pool
\n int maxPoolSize = 4;<\/p>\n
\/\/Keep alive time for waiting threads for jobs(Runnable)
\n long keepAliveTime = 10;<\/p>\n
\/\/This is the one who manages and start the work
\n ThreadPoolExecutor threadPool = null;<\/p>\n
\/\/Working queue for jobs (Runnable). We add them finally here
\n final ArrayBlockingQueue workQueue = new ArrayBlockingQueue(5);<\/p>\n
public MyThreadPoolExecutor() {
\n threadPool = new ThreadPoolExecutor(corePoolSize, maxPoolSize,
\n keepAliveTime, TimeUnit.SECONDS, workQueue);
\n }<\/p>\n
\/**
\n * Here we add our jobs to working queue
\n *
\n * @param task a Runnable task
\n *\/
\n public void runTask(Runnable task) {
\n threadPool.execute(task);
\n System.out.println(„Tasks in workQueue..“ + workQueue.size());
\n }<\/p>\n
\/**
\n * Shutdown the Threadpool if it’s finished
\n *\/
\n public void shutDown() {
\n threadPool.shutdown();
\n }<\/p>\n
public static void main(String args[]) {
\n MyThreadPoolExecutor mtpe = new MyThreadPoolExecutor();<\/p>\n