1+ package javaConcepts .threadpool ;
2+ 3+ import java .util .concurrent .ExecutorService ;
4+ import java .util .concurrent .Executors ;
5+ 6+ class WorkerThread implements Runnable {
7+ private String message ;
8+ public WorkerThread (String s ){
9+ this .message =s ;
10+ }
11+ 12+ public void run () {
13+ System .out .println (Thread .currentThread ().getName ()+" (Start) message = " +message );
14+ processmessage ();
15+ System .out .println (Thread .currentThread ().getName ()+" (End)" );
16+ }
17+ 18+ private void processmessage () {
19+ try { Thread .sleep (2000 ); } catch (InterruptedException e ) { e .printStackTrace (); }
20+ }
21+ 22+ }
23+ 24+ 25+ public class SimpleThreadPool {
26+ 27+ public static void main (String [] args ) {
28+ ExecutorService executor = Executors .newFixedThreadPool (5 );
29+ for (int i = 1 ; i <= 10 ; i ++) {
30+ Runnable worker = new WorkerThread ("" + i );
31+ executor .execute (worker );
32+ }
33+ executor .shutdown ();
34+ while (!executor .isTerminated ()) {
35+ }
36+ System .out .println ("Finished all threads" );
37+ }
38+ 39+ }
0 commit comments