ExecutorService, fängt nicht an

[metalfan]

Hi,

habe hier ein abgeändertes beispiel eines ExecutorService, eigentlich sollte das programm 10*10 in 5 threads ausrechen. aber aus irgendwelchem gründen kommen keine ergebnisse an.
der code "hängt", in eclipse wird das rote kästchen zum abbrechen des programmes viel zu lange angezeigt.

laut beispiel sollte:

for (Future<Integer> contentFuture : contentsFutures) {

so lange warten bis der erste thread in der liste ein ergebnis liefert und dann auf den zweiten warten...

warum aber liefert der code nicht 5x100 aus ausgabe?

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 MultiThreadTest {

	
	
	
	
	
	public int permutationMain() {

		return 10*10;
		
	}
	
	public static void main(String args[]) {
		final ExecutorService pool = Executors.newFixedThreadPool(5);
		
		List<Future<Integer>> contentsFutures = new ArrayList<>();
		
		for (int n=0; n<5; n++) {
		    final Future<Integer> contentFuture = pool.submit(new Callable<Integer>() {
		        @Override
		        public Integer call() throws Exception {
		        	MultiThreadTest x = new MultiThreadTest();
		        	return x.permutationMain();
		            //return IOUtils.toString(new URL("http://" + site), StandardCharsets.UTF_8);
		        }
		    });
		    contentsFutures.add(contentFuture);
		}
		for (Future<Integer> contentFuture : contentsFutures) {
			try {
				final Integer content = contentFuture.get();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (ExecutionException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
			}
	}
}

Quelle: ExecutorCompletionService in Practice | Javalobby

 

[knilch]

Hi,
Der ExecuterService muss terminiert werden. Dies macht er nicht selbständig. Mit shutdown() und awaitTermination().
Siehe Beispiel. Hier wird 5 x 100 ausgegeben und anschliessend beendet..

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;
import java.util.concurrent.TimeUnit;

public class MultiThreadTest {
	public int permutationMain() {
		return 10*10;
	}

	public static void main(String args[]) {
		final ExecutorService pool = Executors.newFixedThreadPool(5);

		List<Future<Integer>> contentsFutures = new ArrayList<>();

		for (int n=0; n<5; n++) {
			final Future<Integer> contentFuture = pool.submit(new Callable<Integer>() {
				@Override
				public Integer call() throws Exception {
					MultiThreadTest x = new MultiThreadTest();
					return x.permutationMain();
				}
			});
			contentsFutures.add(contentFuture);
		}
		for (Future<Integer> contentFuture : contentsFutures) {
			try {
				final Integer content = contentFuture.get();
				System.out.println(content);
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (ExecutionException e) {
				e.printStackTrace();
			}

		}
		
		pool.shutdown();
	    // Wait until all threads are finish
		try {
			pool.awaitTermination(1, TimeUnit.MILLISECONDS);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	    System.out.println("Finished all threads");
	}
}

gruss knilch