auf ende mehrerer threads warten

[Guest]

hallo,

ich schaffe es einfach nicht, zu überprüfen ob z.B. 10 threads durchlaufen sind.

so erstelle ich die threads:

a = new Date();
		
		for (int i=0;i<10;i++){
			Threadtest test = new Threadtest(i);
			vec.add(test);	
			test.start();					
		}

ich habe es so versucht:

new Thread(){
			public void run() {
				boolean laufen = true;
				int i=0;
				while (laufen){	
					i=0;
					for (Iterator iter = vec.iterator(); iter.hasNext();) {
						Threadtest element = (Threadtest) iter.next();	
						if (element.getEnde()){
							i++;								
						}						
					}
					
					if (i>9){
						laufen = false;
						System.out.println("ende");
					}
				}
				Date b = new Date();
				System.out.println("zeit: " + (b.getTime() - a.getTime()));	
			}
		}.start();

dabei muss gesagt werden,
wenn ein thread durchlaufen ist, setze ich intern ein flag, welches ich mit "getEnde()" lese.

mein nächster Versuch war so:

new Thread(){
			public void run() {
				boolean laufen = true;
				int i=0;
				while (laufen){						
					for (Iterator iter = vec.iterator(); iter.hasNext();) {
						Thread element = (Thread) iter.next();	
						if (Thread isInterrupted(){
							i++;								
						}						
					}
					
					if (i>9){
						laufen = false;
						System.out.println("ende");
					}
				}
				Date b = new Date();
				System.out.println("zeit: " + (b.getTime() - a.getTime()));	
			}
		}.start();

doch ich bekomme immer zuers das System.out mit der Zeit,
und danach kommen die System.outs von den Threads.
Die internen System.outs ruf iche auf,wenn ich am ende einer methode angelagen bin.

Danke für die hilfe
[/code]

 

[Guest]

nun klappt es doch, und zwar so:

new Thread(){
			public void run() {
				boolean laufen = true;
				int i=0;
				while (laufen){	
					i=0;
					for (Iterator iter = vec.iterator(); iter.hasNext();) {
						Threadtest element = (Threadtest) iter.next();	
						if (element.getEnde()){
							i++;							
						}						
					}
					try {
						sleep(1);
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					
					if (i==10){
						laufen = false;
						System.out.println("ende");
					}
				}
				Date b = new Date();
				System.out.println("zeit: " + (b.getTime() - a.getTime()));	
			}
		}.start();

kann man das auch anders lösen?
vielleicht eleganter?

 

[kleiner_held]

In Stichpunkten:
java.lang.Thread.join()
Java Insel - Threads und nebenläufige Programmierung