开发者

Java编程一道多线程问题实例代码

前面几篇博文基本上总结了一下java并发里的一些内容,这篇博文主要从一个问题入手,看看都能用到前面总结的哪些并发技术去解决。

题目描述:

模拟一个场景:处理16条日志记录,每条日志记录打印时间需要1秒,正常情况下如果将这16条记录去部打完需要16秒,现在为了提高效率,准备开启4个线程去打印,4秒钟打印完,实现这个demo。

  先来分析一下这个题目,关于这16条日志记录,我们可以在主线程中产生出来,这没用什么难度,关键是开启4个线程去执行,现在有两种思路:一种是编程客栈日志的产生和打印日志的线程在逻辑上分开;一种是日志的产生和打印日志的线程在逻辑上不是分开的。这样说可能有点晦涩,下面我针对这两种思路,写个实现的demo就好理解了。

思路一

日志产生和日志打印在逻辑上是分开的。

  这相当于两条战线: 一条战线在不停的产生日志,另一个战线在不停的打印日志。很明显会想到阻塞队列的使用,产生日志不停的往阻塞队列中塞,打印日志不停的从阻塞队列中取,阻塞队列的大小可以自己设置,可以设置16个,也可以设置为1个,这都不影响执行。所以会用到BlockingQueue,下面看一下实现的demo:

public class Practice1 {
	public static void main(String[] args) {
		//定义一个阻塞队列,队列大小可以装16个信息
		BlockingQueue<String> queue = new ArrayBlockingQueue<String>(16);
		for (int i = 0; i < 4; i ++) {
			//开启四个线程去阻塞队列中取日志打印
			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.current编程客栈TimeMillis()/1000));
		for (int i = 0; i < 16; i ++) {
			final String log = "" + (i+1);
			//表示一个日志
			try {
				queue.put(log);
				//将产生的日志塞到阻塞队列中去
			}
			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();
		}
	}
}

  这就好比一个系统正在运作,一边不停的产生日志,一边在不停的开启多个线程去打印日志信息,这个demo就写好了,运行结果就不贴了。

思路二

日志产生和日志打印在逻辑上不是分开的。

  这种思路就是,我产生日志的同时,你就给我打印出来,四个线程一起干!那么这种思路的话,就得用到线程池了,我一开始创建一个线程池,里面装了4个线程,然后产生日志的时候,我让这个线程池拿线程去执行它即可。demo如下:

public class Practice1 {
	public编程客栈 static void main(String[] args) {
		ExecutorService service = Executors.newFixedThreadPool(4);
		//创建一个线程池
		System.out.println("begin:" + (System.currentTimeMillis()/1000));
		for (int i = 0; i < 16; i ++) {
			final String log = "" + (i+1);
			//表示一个日志
			service.execute(new Runnable() {
				//拿一个线程去执行
				@Override
				        public void run() {
					parseLog(log);
				}
			}
			);
		}
		service.shutdown();
		//最后别忘了关掉线程池
	}
	public static void parseLog(String log) {
		System.out.println(Thread.currentThread().getName() + "---"
		        + log + "---" + (System.currentTi开发者_JS培训meMillis()/1000));
		try {
			Thread.sleep(1000);
			//模拟打印一次日志需要1秒
		}
		catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

关于这个问题,就总结到这吧,把这两种思路搞清楚一般就可以有效的解决了。

总结

以上就是本文关于Java编程一道多线程问题实例代码的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相vgHPboiKp关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!

0

上一篇:

下一篇:

精彩评论

暂无评论...
验证码 换一张
取 消

最新开发

开发排行榜