Java編程一道多線程問題實(shí)例代碼

public class Practice1 {
	public static void main(String[] args) {
		//定義一個(gè)阻塞隊(duì)列，隊(duì)列大小可以裝16個(gè)信息
		BlockingQueue queue = new ArrayBlockingQueue(16);
		for (int i = 0; i < 4; i ++) {
			//開啟四個(gè)線程去阻塞隊(duì)列中取日志打印
			new Thread(new Runnable() {
				@Override
				        public void run() {
					while(true) {
						try {
							String log = queue.take();
							//取日志
							parseLog(log);
							//打印日志
						}
						catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					}
				}
			}
			).start();
		}
		System.out.println("begin:" + (System.currentTimeMillis()/1000));
		for (int i = 0; i < 16; i ++) {
			final String log = "" + (i+1);
			//表示一個(gè)日志
			try {
				queue.put(log);
				//將產(chǎn)生的日志塞到阻塞隊(duì)列中去
			}
			catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	public static void parseLog(String log) {
		//打印日志的方法
		System.out.println(Thread.currentThread().getName() + "---"
		        + log + "---" + (System.currentTimeMillis()/1000));
		try {
			Thread.sleep(1000);
			//模擬打印一次日志需要1秒
		}
		catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

public class Practice1 {
	public static void main(String[] args) {
		ExecutorService service = Executors.newFixedThreadPool(4);
		//創(chuàng)建一個(gè)線程池
		System.out.println("begin:" + (System.currentTimeMillis()/1000));
		for (int i = 0; i < 16; i ++) {
			final String log = "" + (i+1);
			//表示一個(gè)日志
			service.execute(new Runnable() {
				//拿一個(gè)線程去執(zhí)行
				@Override
				        public void run() {
					parseLog(log);
				}
			}
			);
		}
		service.shutdown();
		//最后別忘了關(guān)掉線程池
	}
	public static void parseLog(String log) {
		System.out.println(Thread.currentThread().getName() + "---"
		        + log + "---" + (System.currentTimeMillis()/1000));
		try {
			Thread.sleep(1000);
			//模擬打印一次日志需要1秒
		}
		catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}