mehr Leistung durch Threads

[Q-Base]

Hallo *,

ich würde gerne eine Anwendung 'optimieren'. Das bedeutet, ich würde gerne Mehrkernsysteme ausnutzen, soweit das geht mit der Sun Java RE funktioniert. Bei diesem Thema fühle ich mich als Anfänger, daher habe ich die Frage hierein gepostet.

Gibt es einen guten Guide, mit dem man in die Thread-Programmierung eingeführt wird?

Ich habe schon ein bisschen im Internet gesucht, aber es gibt auch viel 'Müll'. Schlagworte, nach denen ich gesucht habe, waren: Timer, Task, Thread.

Es gibt sicherlich einige Dinge dabei zu beachten. Genau diese Dinge würde ich gerne kennen lernen und nicht in Exceptions rennen.

Habt ihr da was Gutes?

Ciao, Q

 

[Der Müde Joe]

Lesson: Concurrency (The Java™ Tutorials > Essential Classes)

 

[nrg]

http://www.inabrenner.de/pdf/SCJP.pdf

 

[Q-Base]

Hallo Joe & nrg,

vielen Dank für die Links. Sie haben mir sehr geholfen.

Leider habe ich da noch ein Verständnisproblem. Ich möchte später die Klassen nur erweitern, d.h., die Methoden & Interfaces sollen soweit bleiben. Innerhalb der Methoden sollen sich dann 'nur' Threads verbergen. Also habe ich mir eine Klasse geschrieben, in der es zwei Methoden gibt. Die Länge der Ausführung der Methoden verlängere ich künstlich durch eine Schleife bzw. [c]Thread.sleep()[/c].

Ich wollte dabei mir [c]ThreadPoolExecutor[/c] und einer [c]BlockingQueue<Runnable>[/c] arbeiten. Leider werden die beiden Methoden nur nacheinander ausgeführt. Es soll aber so sein, dass die Methoden zwar nacheinander angestoßen werden, die [c]Runnables[/c] darin aber aber innerhalb eines Threads beiläufig & später ausgeführt werden.

Was mache ich also falsch?


Ciao, Q

public class Threadies {

	public static final long WAIT = 16;
	public static final int MAX_COUNT = 8;

	private final ThreadPoolExecutor pool;
	private final BlockingQueue<Runnable> queue;

	public Threadies() {
		queue = new ArrayBlockingQueue<Runnable>(256);
		pool  = new ThreadPoolExecutor(2, 16, (WAIT / 2) , TimeUnit.MILLISECONDS, queue);
	}

	private void zwei() {

		queue.add(new Runnable() {

			@Override
			public void run() {
				
				int count = 0;
				
				while (count < MAX_COUNT) {
					count++;
					System.out.println("zwei " + new Date().toString());
//					try {
//						Thread.sleep(WAIT);
//					}
//					catch (InterruptedException e) {
//						System.err.println("InterruptedException");
//					}
				}
			}
		});
	}

	private void eins() {

		queue.add(new Runnable() {

			@Override
			public void run() {
				
				int count = 0;
				
				while (count < MAX_COUNT) {
					count++;
					System.out.println("eins " + new Date().toString());
//					try {
//						Thread.sleep(WAIT);
//					}
//					catch (InterruptedException e) {
//						System.err.println("InterruptedException");
//					}
				}
			}

		});

	}

	private void stop() {
		pool.shutdown();
	}

	public static void main(String[] args) {

		Threadies t = new Threadies();
		t.eins();
		t.zwei();
		try {
			Thread.sleep(16 * WAIT);
		}
		catch (InterruptedException e) {
			e.printStackTrace();
		}
		t.stop();
	}

}

 

[Q-Base]

Hallo *,

es ist dann doch noch was geworden. Das Geheimnis lag leider nicht im [c]ThreadPoolExecutor[/c], sondern im [c]Executors[/c].

Mit ein wenig Glück bekommt man auf der Console Ausgaben beider Methoden durcheinander.

Ciao, Q

public class Threadies {

	public static final long WAIT = 16;
	public static final int MAX_COUNT = 8;


	private final ExecutorService service;

	public Threadies() {

		service = Executors.newCachedThreadPool();

	}

	private void zwei() {

		service.execute(new Runnable() {

			@Override
			public void run() {

				int count = 0;

				while (count < MAX_COUNT) {
					count++;
					System.out.println(count + " zwei " + new Date().toString());
					try {
						Thread.sleep( WAIT );
					}
					catch (InterruptedException e) {
						System.err.println("InterruptedException");
					}
				}
			}
		});

	}

	private void eins() {

		service.execute(new Runnable() {

			@Override
			public void run() {

				int count = 0;

				while (count < MAX_COUNT) {
					count++;
					System.out.println(count + " eins " + new Date().toString());
					try {
						Thread.sleep( WAIT );
					}
					catch (InterruptedException e) {
						System.err.println("InterruptedException");
					}
				}
			}
		});

	}

	private void stop() {
		service.shutdown();
	}

	public static void main(String[] args) {

		Threadies t = new Threadies();
		t.eins();
		t.zwei();
		try {
			Thread.sleep(16 * WAIT);
		}
		catch (InterruptedException e) {
			e.printStackTrace();
		}
		t.stop();
	}

}