【java并发】一道多线程问题
2016-06-07 17:29
375 查看
前面几篇博文基本上总结了一下java并发里的一些内容,这篇博文主要从一个问题入手,看看都能用到前面总结的哪些并发技术去解决。
题目描述:
模拟一个场景:处理16条日志记录,每条日志记录打印时间需要1秒,正常情况下如果将这16条记录去部打完需要16秒,现在为了提高效率,准备开启4个线程去打印,4秒钟打印完,实现这个demo。
先来分析一下这个题目,关于这16条日志记录,我们可以在主线程中产生出来,这没用什么难度,关键是开启4个线程去执行,现在有两种思路:一种是日志的产生和打印日志的线程在逻辑上分开;一种是日志的产生和打印日志的线程在逻辑上不是分开的。这样说可能有点晦涩,下面我针对这两种思路,写个实现的demo就好理解了。
思路一:日志产生和日志打印在逻辑上是分开的。
这相当于两条战线: 一条战线在不停的产生日志,另一个战线在不停的打印日志。很明显会想到阻塞队列的使用,产生日志不停的往阻塞队列中塞,打印日志不停的从阻塞队列中取,阻塞队列的大小可以自己设置,可以设置16个,也可以设置为1个,这都不影响执行。所以会用到BlockingQueue,下面看一下实现的demo:
这就好比一个系统正在运作,一边不停的产生日志,一边在不停的开启多个线程去打印日志信息,这个demo就写好了,运行结果就不贴了。
思路二:日志产生和日志打印在逻辑上不是分开的。
这种思路就是,我产生日志的同时,你就给我打印出来,四个线程一起干!那么这种思路的话,就得用到线程池了,我一开始创建一个线程池,里面装了4个线程,然后产生日志的时候,我让这个线程池拿线程去执行它即可。demo如下:
关于这个问题,就总结到这吧,把这两种思路搞清楚一般就可以有效的解决了。
相关阅读:http://blog.csdn.net/column/details/bingfa.html
—–乐于分享,共同进步!
—–更多文章请看:http://blog.csdn.net/eson_15
题目描述:
模拟一个场景:处理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.currentTimeMillis()/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.currentTimeMillis()/1000)); try { Thread.sleep(1000); //模拟打印一次日志需要1秒 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
关于这个问题,就总结到这吧,把这两种思路搞清楚一般就可以有效的解决了。
相关阅读:http://blog.csdn.net/column/details/bingfa.html
—–乐于分享,共同进步!
—–更多文章请看:http://blog.csdn.net/eson_15
相关文章推荐
- 函数重载
- spring3.2.4+mybatis3.2.3在maven下的整合
- CXF开发webservice需要的最少jar包
- Java多线程 之 后台线程(四)
- 【Eclipse】Eclipse里项目的包层次结构排版问题
- spring---定时任务
- Spring基础知识
- java: -source 1.6 中不支持 switch 中存在字符串 和 "compileDebugJavaWithJavac"的错误解决
- JDK8新特性 Java调用js
- Eclipse启动速度很慢的优化
- 如何通过apt-get 安装jdk
- SpringMVC中Type [java.lang.String] is not valid for option items 的报错
- JavaWeb系列-JSP基础语法
- 做Java Web项目过程中遇到的几个问题及解决方案
- eclipse问题 import java.io cannot be resolved
- Spring事务配置的五种方式
- java中如何在eclipse里查看一个接口的所有实现类或一个类的子父级关系?
- Eclipse常用设置
- Spring MVC 入门概要 1
- Java注解