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.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();
}
}
}
关于这个问题，就总结到这吧，把这两种思路搞清楚一般就可以有效的解决了。
总结
以上就是本文关于Java编程一道多线程问题实例代码的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
您可能感兴趣的文章:
- 2018年java技术面试题整理
- java中jvm逃逸问题分析
- Java并发编程this逃逸问题总结
- Java中的逃逸问题心得
- java数组排列组合问题汇总
- java实现字符串排列组合问题
- Java ArrayList扩容问题实例详解
- Java面试题解析之判断以及防止SQL注入
- java彩色瓷砖编程题分析
相关推荐
-
Java面试题解析之判断以及防止SQL注入
本文研究的主要是Java面试题中的一个比较常见的题目,判断及防止SQL注入的问题,具体介绍如下. SQL注入是目前黑客最常用的攻击手段,它的原理是利用数据库对特殊标识符的解析强行从页面向后台传入.改变SQL语句结构,达到扩展权限.创建高等级用户.强行修改用户资料等等操作. 那怎么判断是否被SQL注入了呢? 通过SQL注入的原理我们知道,判断SQL注入可以通过页面传入的数据,后台不应该相信从后台传入的任何数据特别是特殊整型参数和特殊字符参数! 防止SQL注入其实也很简单 1.检查变量数据类型和格式
-
Java中的逃逸问题心得
大家一般认为new出来的对象都是被分配在堆上,但这并不是完全正确,通过对Java对象分配过程分析,我们发现对象除了可以被分配在堆上,还可以在栈或TLAB中分配空间.而栈上分配对象的技术基础是逃逸分析和标量替换,本文主要介绍下逃逸分析. 逃逸分析的定义 逃逸分析,是一种可以有效减少Java 程序中同步负载和内存堆分配压力的跨函数全局数据流分析算法. 通过逃逸分析,Java Hotspot编译器能够分析出一个新的对象的引用的使用范围从而决定是否要将这个对象分配到堆上. Java在Java SE 6u
-
java实现字符串排列组合问题
本文为大家介绍了java实现字符串排列组合问题,供大家参考,具体内容如下 import java.util.ArrayList; import java.util.Collections; /** * 输入一个字符串,按字典序打印出该字符串中字符的所有排列.例如输入字符串abc,则打印出由字符a,b,c所能排列出来的所有字符串abc,acb,bac, * bca,cab和cba. * * @author pomay * */ public class Solution_stringarrange
-
Java ArrayList扩容问题实例详解
本文研究的主要是Java ArrayList扩容问题实例详解的相关内容,具体介绍如下. 首先我们需要知道ArrayList里面的实质的其实是一个Object类型的数组,ArrayList的扩容问题其实就是这个Object类型的数组的扩容问题. transient Object[] elementData; 一.创建时,ArrayList的容量分配 创建一个ArrayList有三种情况 1.默认大小创建(默认为0) ArrayList al = new ArrayList(); 创建完成之后,al
-
java彩色瓷砖编程题分析
牛牛喜欢彩色的东西,尤其是彩色的瓷砖.牛牛的房间内铺有L块正方形瓷砖.每块砖的颜色有四种可能:红.绿.蓝.黄.给定一个字符串S, 如果S的第i个字符是'R', 'G', 'B'或'Y',那么第i块瓷砖的颜色就分别是红.绿.蓝或者黄. 牛牛决定换掉一些瓷砖的颜色,使得相邻两块瓷砖的颜色均不相同.请帮牛牛计算他最少需要换掉的瓷砖数量. 输入描述: 输入包括一行,一个字符串S,字符串长度length(1 ≤ length ≤ 10),字符串中每个字符串都是'R', 'G', 'B'或者'Y'. 输出描
-
Java并发编程this逃逸问题总结
this逃逸是指在构造函数返回之前其他线程就持有该对象的引用. 调用尚未构造完全的对象的方法可能引发令人疑惑的错误, 因此应该避免this逃逸的发生. this逃逸经常发生在构造函数中启动线程或注册监听器时, 如: public class ThisEscape { public ThisEscape() { new Thread(new EscapeRunnable()).start(); // ... } private class EscapeRunnable implements Run
-
java中jvm逃逸问题分析
引言: 逃逸分析(Escape Analysis)是众多JVM技术中的一个使用不多的技术点,本文将通过一个实例来分析其使用场景. 概念 逃逸分析,是一种可以有效减少Java 程序中同步负载和内存堆分配压力的跨函数全局数据流分析算法.通过逃逸分析,Java Hotspot编译器能够分析出一个新的对象的引用的使用范围从而决定是否要将这个对象分配到堆上. 在计算机语言编译器优化原理中,逃逸分析是指分析指针动态范围的方法,它同编译器优化原理的指针分析和外形分析相关联.当变量(或者对象)在方法中分配后,其
-
2018年java技术面试题整理
1.servlet执行流程 客户端发出http请求,web服务器将请求转发到servlet容器,servlet容器解析url并根据web.xml找到相对应的servlet,并将request.response对象传递给找到的servlet,servlet根据request就可以知道是谁发出的请求,请求信息及其他信息,当servlet处理完业务逻辑后会将信息放入到response并响应到客户端. 2.springMVC的执行流程 springMVC是由dispatchservlet为核心的分层控制
-
java数组排列组合问题汇总
面试或笔试中,多次遇到以下4个关于排列组合的手撕算法,这里做个笔记,方法日后查阅: 1. 无重复元素的数组,求全排列: 2. 有重复元素的数组,求全排列: 3. 无重复元素的数组,求组合[子集]: 4. 有重复元素的数组,求组合: 以上四类题,可以用统一的模板实现,如下所示: /* *[组合&&排列] *把一个数组里的数组合全部列出,比如1和2列出来为1,2,12,21. *这个题目可以扩展成四个: *1.无重复数字的数组,求组合 *2.有重复数字的数组,求组合 *3.无重复数字的数组,求
-
Java编程一道多线程问题实例代码
前面几篇博文基本上总结了一下java并发里的一些内容,这篇博文主要从一个问题入手,看看都能用到前面总结的哪些并发技术去解决. 题目描述: 模拟一个场景:处理16条日志记录,每条日志记录打印时间需要1秒,正常情况下如果将这16条记录去部打完需要16秒,现在为了提高效率,准备开启4个线程去打印,4秒钟打印完,实现这个demo. 先来分析一下这个题目,关于这16条日志记录,我们可以在主线程中产生出来,这没用什么难度,关键是开启4个线程去执行,现在有两种思路:一种是日志的产生和打印日志的线程在逻辑上分开
-
Java编程几个循环实例代码分享
有关Java循环的内容,编程中还是比较常用的,下面分享给大家几个循环的示例代码,练习一下. 1.循环输出1到100之间所有能被3或能被4整除的数. package com.hz.loop02; /** * 1.循环输出1到100之间所有能被3或能被4整除的数. * @author ztw * */ public class Practice01 { public static void main(String[] args) { for (int i=1;i<=100;i++){ //判断下是否
-
Java编程实现打地鼠文字游戏实例代码
控制台输入数字,与随机数匹配,匹配正确则返回"打中了!" 匹配错误则返回"太遗憾!没打中!" package hitmouse; import java.util.Random; import java.util.Scanner; public class HitMouse { public static void main(String[] args) { // TODO Auto-generated method stub int[] map = new int
-
Java编程实现swing圆形按钮实例代码
Swing是一个为Java设计的GUI工具包. Swing是JAVA基础类的一部分. Swing包括了图形用户界面(GUI)器件如:文本框,按钮,分隔窗格和表. Swing提供许多比AWT更好的屏幕显示元素.它们用纯Java写成,所以同Java本身一样可以跨平台运行,这一点不像AWT.它们是JFC的一部分.它们支持可更换的面板和主题(各种操作系统默认的特有主题),然而不是真的使用原生平台提供的设备,而是仅仅在表面上模仿它们.这意味着你可以在任意平台上使用JAVA支持的任意面板.轻量级组件的缺点则
-
Java编程实现多线程TCP服务器完整实例
相关Java类 Socket public class Socket extends Object ·功能:TCP客户端套接字 ·构造方法: Socket(InetAddress address, int port) 创建一个流套接字并将其连接到指定 IP 地址的指定端口号 ·常用方法: 1.getInetAddress 获得InetAddress的相关信息 2.getInputStream 获得此TCP连接的输入流 3.getOutPutStream 获得此TCP连接的输出流 ServerSo
-
Java编程之多线程死锁与线程间通信简单实现代码
死锁定义 死锁是指两个或者多个线程被永久阻塞的一种局面,产生的前提是要有两个或两个以上的线程,并且来操作两个或者多个以上的共同资源:我的理解是用两个线程来举例,现有线程A和B同时操作两个共同资源a和b,A操作a的时候上锁LockA,继续执行的时候,A还需要LockB进行下面的操作,这个时候b资源在被B线程操作,刚好被上了锁LockB,假如此时线程B刚好释放了LockB则没有问题,但没有释放LockB锁的时候,线程A和B形成了对LockB锁资源的争夺,从而造成阻塞,形成死锁:具体其死锁代码如下:
-
Java Socket编程服务器响应客户端实例代码
通过输入流来读取客户端信息,相应的时候通过输出流来实现. 服务端类的代码: import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; impo
-
Python编程scoketServer实现多线程同步实例代码
本文研究的主要是Python编程scoketServer实现多线程同步的相关内容,具体介绍如下. 开发过程中,为了实现不同的客户端同一时刻只能有一个使用共同数据. 虽说用Python编写简单的网络程序很方便,但复杂一点的网络程序还是用现成的框架比较好.这样就可以专心事务逻辑,而不是套接字的各种细节.SocketServer模块简化了编写网络服务程序的任务.同时SocketServer模块也是Python标准库中很多服务器框架的基础. 网络服务类: SocketServer提供了4个基本的服务类:
-
Java构建树形菜单的实例代码(支持多级菜单)
效果图:支持多级菜单. 菜单实体类: public class Menu { // 菜单id private String id; // 菜单名称 private String name; // 父菜单id private String parentId; // 菜单url private String url; // 菜单图标 private String icon; // 菜单顺序 private int order; // 子菜单 private List<Menu> children;
-
Java编程redisson实现分布式锁代码示例
最近由于工作很忙,很长时间没有更新博客了,今天为大家带来一篇有关Redisson实现分布式锁的文章,好了,不多说了,直接进入主题. 1. 可重入锁(Reentrant Lock) Redisson的分布式可重入锁RLock Java对象实现了java.util.concurrent.locks.Lock接口,同时还支持自动过期解锁. public void testReentrantLock(RedissonClient redisson){ RLock lock = redisson.getL