后使用快捷导航没有帐号？
查看: 7822|回复: 12
如何在j2ee项目中处理高并发量访问？（面试题）
金牌会员, 积分 1373, 距离下一级还需 1627 积分
论坛徽章:20
大概就是这几方面吧
一个小型的网站，可以使用最简单的html静态页面就实现了，配合一些图片达到美化效果，所有的页面均存放在一个目录下，这样的网站对系统架构、性能的要求都很简单。随着互联网业务的不断丰富，网站相关的技术经过这些年的发展，已经细分到很细的方方面面，尤其对于大型网站来说，所采用的技术更是涉及面非常广，从硬件到软件、编程语言、数据库、WebServer、防火墙等各个领域都有了很高的要求，已经不是原来简单的html静态网站所能比拟的。　　大型网站，比如门户网站，在面对大量用户访问、高并发请求方面，基本的解决方案集中在这样几个环节：使用高性能的服务器、高性能的数据库、高效率的编程语言、还有高性能的Web容器。这几个解决思路在一定程度上意味着更大的投入。1、HTML静态化　　其实大家都知道，效率最高、消耗最小的就是纯静态化的html页面，所以我们尽可能使我们的网站上的页面采用静态页面来实现，这个最简单的方法其实也是最有效的方法。但是对于大量内容并且频繁更新的网站，我们无法全部手动去挨个实现，于是出现了我们常见的信息发布系统CMS，像我们常访问的各个门户站点的新闻频道，甚至他们的其他频道，都是通过信息发布系统来管理和实现的，信息发布系统可以实现最简单的信息录入自动生成静态页面，还能具备频道管理、权限管理、自动抓取等功能，对于一个大型网站来说，拥有一套高效、可管理的CMS是必不可少的。　　除了门户和信息发布类型的网站，对于交互性要求很高的社区类型网站来说，尽可能的静态化也是提高性能的必要手段，将社区内的帖子、文章进行实时的静态化、有更新的时候再重新静态化也是大量使用的策略，像Mop的大杂烩就是使用了这样的策略，网易社区等也是如此。　　同时，html静态化也是某些缓存策略使用的手段，对于系统中频繁使用数据库查询但是内容更新很小的应用，可以考虑使用html静态化来实现。比如论坛中论坛的公用设置信息，这些信息目前的主流论坛都可以进行后台管理并且存储在数据库中，这些信息其实大量被前台程序调用，但是更新频率很小，可以考虑将这部分内容进行后台更新的时候进行静态化，这样避免了大量的数据库访问请求。2、图片服务器分离　　大家知道，对于Web服务器来说，不管是Apache、IIS还是其他容器，图片是最消耗资源的，于是我们有必要将图片与页面进行分离，这是基本上大型网站都会采用的策略，他们都有独立的、甚至很多台的图片服务器。这样的架构可以降低提供页面访问请求的服务器系统压力，并且可以保证系统不会因为图片问题而崩溃。　　在应用服务器和图片服务器上，可以进行不同的配置优化，比如apache在配置ContentType的时候可以尽量少支持、尽可能少的LoadModule，保证更高的系统消耗和执行效率。3、数据库集群、库表散列　　大型网站都有复杂的应用，这些应用必须使用数据库，那么在面对大量访问的时候，数据库的瓶颈很快就能显现出来，这时一台数据库将很快无法满足应用，于是我们需要使用数据库集群或者库表散列。　　在数据库集群方面，很多数据库都有自己的解决方案，Oracle、Sybase等都有很好的方案，常用的My提供的Master/Slave也是类似的方案，您使用了什么样的DB，就参考相应的解决方案来实施即可。　　上面提到的数据库集群由于在架构、成本、扩张性方面都会受到所采用DB类型的限制，于是我们需要从应用程序的角度来考虑改善系统架构，库表散列是常用并且最有效的解决方案。　　我们在应用程序中安装业务和应用或者功能模块将数据库进行分离，不同的模块对应不同的数据库或者表，再按照一定的策略对某个页面或者功能进行更小的数据库散列，比如用户表，按照用户ID进行表散列，这样就能够低成本的提升系统的性能并且有很好的扩展性。　　sohu的论坛就是采用了这样的架构，将论坛的用户、设置、帖子等信息进行数据库分离，然后对帖子、用户按照板块和ID进行散列数据库和表，最终可以在配置文件中进行简单的配置便能让系统随时增加一台低成本的数据库进来补充系统性能。4、缓存　　缓存一词搞技术的都接触过，很多地方用到缓存。网站架构和网站开发中的缓存也是非常重要。这里先讲述最基本的两种缓存。高级和分布式的缓存在后面讲述。　　架构方面的缓存，对Apache比较熟悉的人都能知道Apache提供了自己的缓存模块，也可以使用外加的Squid模块进行缓存，这两种方式均可以有效的提高Apache的访问响应能力。　　网站程序开发方面的缓存，上提供的Memory Cache是常用的缓存接口，可以在web开发中使用，比如用开发的时候就可以调用MemoryCache对一些数据进行缓存和通讯共享，一些大型社区使用了这样的架构。另外，在使用web语言开发的时候，各种语言基本都有自己的缓存模块和方法，PHP有Pear的Cache模块，Java就更多了，.net不是很熟悉，相信也肯定有。5、镜像　　镜像是大型网站常采用的提高性能和数据安全性的方式，镜像的技术可以解决不同网络接入商和地域带来的用户访问速度差异，比如ChinaNet和EduNet之间的差异就促使了很多网站在教育网内搭建镜像站点，数据进行定时更新或者实时更新。在镜像的细节技术方面，这里不阐述太深，有很多专业的现成的解决架构和产品可选。也有廉价的通过软件实现的思路，比如Linux上的rsync等工具。6、负载均衡　　负载均衡将是大型网站解决高负荷访问和大量并发请求采用的高端解决办法。
　　负载均衡技术发展了多年，有很多专业的服务提供商和产品可以选择，我个人接触过一些解决方法，其中有两个架构可以给大家做参考。（1）、硬件四层交换　　第四层交换使用第三层和第四层信息包的报头信息，根据应用区间识别业务流，将整个区间段的业务流分配到合适的应用服务器进行处理。　　第四层交换功能就像是虚IP，指向物理服务器。它传输的业务服从的协议多种多样，有HTTP、FTP、NFS、Telnet或其他协议。这些业务在物理服务器基础上，需要复杂的载量平衡。在IP世界，业务类型由终端TCP或UDP端口地址来决定，在第四层交换中的应用区间则由源端和终端IP地址、TCP和UDP端口共同决定。　　在硬件四层交换产品领域，有一些知名的产品可以选择，比如Alteon、F5等，这些产品很昂贵，但是物有所值，能够提供非常优秀的性能和很灵活的管理能力。“Yahoo中国”当初接近2000台服务器，只使用了三、四台Alteon就搞定了。(2)、软件四层交换　　大家知道了硬件四层交换机的原理后，基于OSI模型来实现的软件四层交换也就应运而生，这样的解决方案实现的原理一致，不过性能稍差。但是满足一定量的压力还是游刃有余的，有人说软件实现方式其实更灵活，处理能力完全看你配置的熟悉能力。　　软件四层交换我们可以使用Linux上常用的LVS来解决，LVS就是Linux Virtual Server，他提供了基于心跳线heartbeat的实时灾难应对解决方案，提高系统的强壮性，同时可供了灵活的虚拟VIP配置和管理功能，可以同时满足多种应用需求，这对于分布式的系统来说必不可少。　　一个典型的使用负载均衡的策略就是，在软件或者硬件四层交换的基础上搭建squid集群，这种思路在很多大型网站包括搜索引擎上被采用，这样的架构低成本、高性能还有很强的扩张性，随时往架构里面增减节点都非常容易。　　对于大型网站来说，前面提到的每个方法可能都会被同时使用到，这里介绍得比较浅显，具体实现过程中很多细节还需要大家慢慢熟悉和体会。有时一个很小的squid参数或者apache参数设置，对于系统性能的影响就会很大。7、最新：CDN加速技术什么是CDN？　　 CDN的全称是内容分发网络。其目的是通过在现有的Internet中增加一层新的网络架构，将网站的内容发布到最接近用户的网络“边缘”，使用户可以就近取得所需的内容，提高用户访问网站的响应速度。　　CDN有别于镜像，因为它比镜像更智能，或者可以做这样一个比喻：CDN=更智能的镜像+缓存+流量导流。因而，CDN可以明显提高Internet网络中信息流动的效率。从技术上全面解决由于网络带宽小、用户访问量大、网点分布不均等问题，提高用户访问网站的响应速度。CDN的类型特点　 　CDN的实现分为三类：镜像、高速缓存、专线。　　镜像站点（Mirror Site），是最常见的，它让内容直接发布，适用于静态和准动态的数据同步。但是购买和维护新服务器的费用较高，还必须在各个地区设置镜像服务器，配备专业技术人员进行管理与维护。对于大型网站来说，更新所用的带宽成本也大大提高了。　　高速缓存，成本较低，适用于静态内容。Internet的统计表明，超过80%的用户经常访问的是20%的网站的内容，在这个规律下，缓存服务器可以处理大部分客户的静态请求，而原始的服务器只需处理约20%左右的非缓存请求和动态请求，于是大大加快了客户请求的响应时间，并降低了原始服务器的负载。　　CDN服务一般会在全国范围内的关键节点上放置缓存服务器。　　专线，让用户直接访问数据源，可以实现数据的动态同步。CDN的实例　　举个例子来说，当某用户访问网站时，网站会利用全球负载均衡技术，将用户的访问指向到距离用户最近的正常工作的缓存服务器上，直接响应用户的请求。　　当用户访问已经使用了CDN服务的网站时，其解析过程与传统解析方式的最大区别就在于网站的授权域名服务器不是以传统的轮询方式来响应本地DNS的解析请求，而是充分考虑用户发起请求的地点和当时网络的情况，来决定把用户的请求定向到离用户最近同时负载相对较轻的节点缓存服务器上。　　通过用户定位算法和服务器健康检测算法综合后的数据，可以将用户的请求就近定向到分布在网络“边缘”的缓存服务器上，保证用户的访问能得到更及时可靠的响应。　　由于大量的用户访问都由分布在网络边缘的CDN节点缓存服务器直接响应了，这就不仅提高了用户的访问质量，同时有效地降低了源服务器的负载压力。附：某CDN服务商的服务说明
采用GCDN加速方式　　采用了GCDN加速方式以后，系统会在浏览用户和您的服务器之间增加一台GCDN服务器。浏览用户访问您的服务器时，一般静态数据，如图片、多媒体资料等数据将直接从GCDN服务器读取，使得从主服务器上读取静态数据的交换量大大减少。　　为VIP型虚拟主机而特加的VPN高速压缩通道，使用高速压缩的电信&==&网通、电信&==&国际（HK）、网通&==&国际（HK）等跨网专线通道，智能多线，自动获取最快路径，极速的动态实时并发响应速度，实现了网站的动态脚本实时同步，对动态网站有一个更加明显的加速效果。
高级会员, 积分 570, 距离下一级还需 430 积分
论坛徽章:11
这好像和J2EE没有太大的关系。
高级会员, 积分 782, 距离下一级还需 218 积分
论坛徽章:21
题目和内容确实有差距
中级会员, 积分 486, 距离下一级还需 14 积分
论坛徽章:18
总结的不错，现实工作中基本都是这么些解决思路
注册会员, 积分 66, 距离下一级还需 134 积分
论坛徽章:9
其实，关于这些内容都是需要仔细的学习和归纳总结的，其实分门别类特别多，这块确实需要仔细的琢磨和研究啊
金牌会员, 积分 1626, 距离下一级还需 1374 积分
论坛徽章:8
多多总结总是好的，有很多类似的技术需要分类总结
高级会员, 积分 619, 距离下一级还需 381 积分
论坛徽章:19
说到了很多的技术，记录下留着看，哈哈
中级会员, 积分 224, 距离下一级还需 276 积分
论坛徽章:10
貌似和主题有点出入哦& &&&
论坛徽章:45
谢谢楼主分享，以后面试用的上
新手上路, 积分 1, 距离下一级还需 49 积分
论坛徽章:0
不要在这样找笔试题了，一次就这么几个，还没过瘾就没有了，去安装个《笔试宝典》收录了网上90%的笔试题/
扫一扫加入本版微信群java多线程和并发包入门示例
字体：[ ] 类型：转载 时间：
这篇文章主要写了java多线程的使用方法和java并发包简单入门的示例，大家可以参考使用
一、java多线程基本入门java多线程编程还是比较重要的，在实际业务开发中经常要遇到这个问题。 java多线程，传统创建线程的方式有两种。 1、继承自Thread类，覆写run方法。 2、实现Runnable接口，实现run方法。 启动线程的方法都是调用start方法，真正执行调用的是run方法。参考代码如下：
代码如下:package com.jack.
/**&* 线程简单演示例子程序&* &* @author pinefantasy&* @since &*/public class ThreadDemo1 {
&&& /**&&&& * 第一种方式：继承自Thread类，覆写run方法&&&& */&&& public static class Test1Thread extends Thread {
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&& System.out.println("Test1," + Thread.currentThread().getName() + ", i = " + i);&&&&&&&&&&& }&&&&&&& }&&& }
&&& /**&&&& * 第二种方式：实现Runnable接口，实现run方法&&&& */&&& public static class Test2Thread implements Runnable {
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&& System.out.println("Test2," + Thread.currentThread().getName() + ", i = " + i);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * &pre&&&&& * &&&& * 主线程为main线程&&&& * 分支线程为：1 2 3 三种简单实现方式&&&& * &&&& * @param args&&&& */&&& public static void main(String[] args) {&&&&&&& new Test1Thread().start();// 启动线程1&&&&&&& new Thread(new Test2Thread()).start();// 启动线程2&&&&&&& new Thread(new Runnable() {
&&&&&&&&&&& @Override&&&&&&&&&&& public void run() {&&&&&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&&&&&& System.out.println("Test3," + Thread.currentThread().getName() + ", i = " + i);&&&&&&&&&&&&&&& }&&&&&&&&&&& }&&&&&&& }).start();// 启动线程3&&& }
二、java并发包简单入门多个线程，统一处理同一个变量演示代码：
代码如下:package com.jack.
import java.util.concurrent.atomic.AtomicI
/**&* 多线程对同一个变量进行操作&* &* @author pinefantasy&* @since &*/public class ThreadDemo2 {
&&& private static int count = 0;
&&& public static class CountThread implements Runnable {// 1.这边有线程安全问题，共享变量乱套了
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&& try {&&&&&&&&&&&&&&&&&&& Thread.sleep(50);&&&&&&&&&&&&&&& } catch (InterruptedException e) {&&&&&&&&&&&&&&&&&&& e.printStackTrace();&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& count++;&&&&&&&&&&&&&&& System.out.println(Thread.currentThread().getName() + ", count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& private static final Object lock = new Object();// 这边使用的lock对象
&&& public static class Count2Thread implements Runnable {// 这边使用的是互斥锁方式
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& synchronized (lock) {// 使用互斥锁方式处理&&&&&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&&&&&& count++;&&&&&&&&&&&&&&&&&&& System.out.println(Thread.currentThread().getName() + ", count = " + count);&&&&&&&&&&&&&&& }&&&&&&&&&&& }&&&&&&& }
&&& private static AtomicInteger ai = new AtomicInteger();// 这边使用的是并发包的AtomicXXX类，使用的是CAS方式：compare and swap
&&& public static class Count3Thread implements Runnable {// AtomicInteger内部的CAS实现方式，采用的是：循环、判断、设置三部曲方式
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&& int tmp = ai.incrementAndGet();// 采用CAS方式处理&&&&&&&&&&&&&&& System.out.println(Thread.currentThread().getName() + ", count = " + tmp);&&&&&&&&&&& }&&&&&&& }
&&& private static volatile int countV = 0;// 定义成volatile，让多线程感知，因为值是放在主存中
&&& public static class Count4Thread implements Runnable {// volatile定义的变量只是说放到了主存，当时++操作并不是原子操作，这个要小心
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {&&&&&&&&&&&&&&& try {&&&&&&&&&&&&&&&&&&& Thread.sleep(50);// 这边让线程休眠下，增加出错概率&&&&&&&&&&&&&&& } catch (InterruptedException e) {&&&&&&&&&&&&&&&&&&& e.printStackTrace();&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& countV++;// volatile要正确使用，不是说定义成volatile就是安全的，还是要注意++ --操作并不是原子操作&&&&&&&&&&&&&&& System.out.println(Thread.currentThread().getName() + ", count = " + countV);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 使用泛型简单编写一个测试方法&&&& * &&&& * @param &T&&&&& * @param t&&&& * @throws InstantiationException&&&& * @throws IllegalAccessException&&&& * @throws InterruptedException&&&& */&&& public static &T& void testTemplate(T t) throws InstantiationException, IllegalAccessException, InterruptedException {&&&&&&& for (int i = 0; i & 5; i++) {&&&&&&&&&&& if (t instanceof Runnable) {&&&&&&&&&&&&&&& Class&?& c = t.getClass();&&&&&&&&&&&&&&& Object object = c.newInstance();&&&&&&&&&&&&&&& new Thread((Runnable) object).start();&&&&&&&&&&& }&&&&&&& }&&& }
&&& /**&&&& * &pre&&&&& * 1.test1 线程不安全演示例子，count变量不能得到预期的效果&&&& * 2.test2 在test1基础上改进的，用互斥锁sync处理&&&& * 3.test3 在test1基础上改进的，用AtomicInteger类来实现&&&& * 4.test4 有问题的方法，因为i++并不是原子操作，将count定义为volatile类型的&&&& * &&&& * @param args&&&& * @throws InterruptedException&&&& * @throws IllegalAccessException&&&& * @throws InstantiationException&&&& */&&& public static void main(String[] args) throws InterruptedException, InstantiationException, IllegalAccessException {&&&&&&& // 1.测试1&&&&&&& // testTemplate(new CountThread());&&&&&&& // 2.测试2&&&&&&& // testTemplate(new Count2Thread());&&&&&&& // 3.测试3&&&&&&& // testTemplate(new Count3Thread());&&&&&&& // 4.测试4&&&&&&& testTemplate(new Count4Thread());&&&&&&& Thread.sleep(15000);&&&&&&& System.out.println(count);&&&&&&& System.out.println(ai.get());&&&&&&& System.out.println(countV);&&& }
生产者-消费者模式生产者（生成产品的线程）--》负责生成产品 消费者（消费产品的线程）--》负责消费产品买车人、消费者。 卖车人、销售汽车的人、姑且当做生产者。 仓库、存放汽车的地方。 汽车工厂、真实生成汽车的地方。参考代码如下：// 没有加上同步机制的代码如下：
代码如下:package com.jack.
import java.util.ArrayLimport java.util.Limport com.jack.thread.ThreadDemo3.CarBigHouse.C
/**&* 第一个版本的生产者和消费者线程&* &* @author pinefantasy&* @since &*/public class ThreadDemo3 {
&&& /**&&&& * 姑且卖车的当做是生产者线程&&&& */&&& public static class CarSeller implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public CarSeller(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做生产者线程，往仓库里边增加汽车，其实是触发增加汽车&&&&&&&&&&&&&&& int count = bigHouse.put();&&&&&&&&&&&&&&& System.out.println("生产汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 姑且买车的人当做是消费者线程&&&& */&&& public static class Consumer implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public Consumer(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做消费者线程，从仓库里边提取汽车，其实是触发，从仓库里边提取一辆汽车出来&&&&&&&&&&&&&&& int count = bigHouse.get();&&&&&&&&&&&&&&& System.out.println("消费汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 这边姑且当做是车子big house放车子的仓库房&&&& */&&& public static class CarBigHouse {
&&&&&&& public int carNums = 0;// 这边是仓库房子中车子的数量总数&&&&&&& public List&Car& carList = new ArrayList&Car&();// 这边模拟用来放汽车的list
&&&&&&& public int put() {// 提供给生产者放汽车到仓库的接口&&&&&&&&&&& Car car = CarFactory.makeNewCar();&&&&&&&&&&& carList.add(car);// 加到仓库中去&&&&&&&&&&& carNums++;// 总数增加1&&&&&&&&&&& return carN&&&&&&& }
&&&&&&& public int get() {// 提供给消费者从这边取汽车接口&&&&&&&&&&& Car car =&&&&&&&&&&& if (carList.size() != 0) {// size不为空才去取车&&&&&&&&&&&&&&& car = carList.get(carList.size() - 1);// 提取最后一个car&&&&&&&&&&&&&&& carList.remove(car);// 从从库list中移除掉&&&&&&&&&&&&&&& carNums--;// 总数减少1&&&&&&&&&&& }&&&&&&&&&&& return carN&&&&&&& }
&&&&&&& public static class Car {
&&&&&&&&&&& public String carN// 汽车名称&&&&&&&&&&& public double carP// 汽车价格
&&&&&&&&&&& public Car() {&&&&&&&&&&& }
&&&&&&&&&&& public Car(String carName, double carPrice) {&&&&&&&&&&&&&&& this.carName = carN&&&&&&&&&&&&&&& this.carPrice = carP&&&&&&&&&&& }&&&&&&& }&&& }
&&& /**&&&& * 采用静态工厂方式创建car对象，这个只是简单模拟，不做设计模式上的过多考究&&&& */&&& public static class CarFactory {
&&&&&&& private CarFactory() {&&&&&&& }
&&&&&&& public static Car makeNewCar(String carName, double carPrice) {&&&&&&&&&&& return new Car(carName, carPrice);&&&&&&& }
&&&&&&& public static Car makeNewCar() {&&&&&&&&&&& return new Car();&&&&&&& }&&& }
&&& /**&&&& * 第一个版本的生产者和消费者线程，没有加上同步机制的演示例子&&&& * &&&& * @param args&&&& */&&& public static void main(String[] args) {&&&&&&& CarBigHouse bigHouse = new CarBigHouse();&&&&&&& new Thread(new CarSeller(bigHouse)).start();&&&&&&& new Thread(new Consumer(bigHouse)).start();&&& }
// 加上互斥锁的代码如下：
代码如下:package com.jack.
import java.util.ArrayLimport java.util.Limport com.jack.thread.ThreadDemo4.CarBigHouse.C
/**&* 第二个版本的生产者消费者线程&* &* @author pinefantasy&* @since &*/public class ThreadDemo4 {
&&& /**&&&& * 姑且卖车的当做是生产者线程&&&& */&&& public static class CarSeller implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public CarSeller(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做生产者线程，往仓库里边增加汽车，其实是触发增加汽车&&&&&&&&&&&&&&& int count = bigHouse.put();&&&&&&&&&&&&&&& System.out.println("生产汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 姑且买车的人当做是消费者线程&&&& */&&& public static class Consumer implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public Consumer(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做消费者线程，从仓库里边提取汽车，其实是触发，从仓库里边提取一辆汽车出来&&&&&&&&&&&&&&& int count = bigHouse.get();&&&&&&&&&&&&&&& System.out.println("消费汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 这边姑且当做是车子big house放车子的仓库房&&&& */&&& public static class CarBigHouse {
&&&&&&& public int carNums = 0;// 这边是仓库房子中车子的数量总数&&&&&&& public List&Car& carList = new ArrayList&Car&();// 这边模拟用来放汽车的list&&&&&&& // 直接增加上synchronized关键字方式，成员方法，锁的是当前bigHouse对象&&&&&&& // 这种锁是互斥锁，方法在同一个时刻，只有一个线程可以访问到里边的代码
&&&&&&& public synchronized int put() {// 提供给生产者放汽车到仓库的接口&&&&&&&&&&& Car car = CarFactory.makeNewCar();&&&&&&&&&&& carList.add(car);// 加到仓库中去&&&&&&&&&&& carNums++;// 总数增加1&&&&&&&&&&& return carN&&&&&&& }
&&&&&&& public synchronized int get() {// 提供给消费者从这边取汽车接口&&&&&&&&&&& Car car =&&&&&&&&&&& if (carList.size() != 0) {// size不为空才去取车&&&&&&&&&&&&&&& car = carList.get(carList.size() - 1);// 提取最后一个car&&&&&&&&&&&&&&& carList.remove(car);// 从从库list中移除掉&&&&&&&&&&&&&&& carNums--;// 总数减少1&&&&&&&&&&& }&&&&&&&&&&& return carN&&&&&&& }
&&&&&&& public static class Car {
&&&&&&&&&&& public String carN// 汽车名称&&&&&&&&&&& public double carP// 汽车价格
&&&&&&&&&&& public Car() {&&&&&&&&&&& }
&&&&&&&&&&& public Car(String carName, double carPrice) {&&&&&&&&&&&&&&& this.carName = carN&&&&&&&&&&&&&&& this.carPrice = carP&&&&&&&&&&& }&&&&&&& }&&& }
&&& /**&&&& * 采用静态工厂方式创建car对象，这个只是简单模拟，不做设计模式上的过多考究&&&& */&&& public static class CarFactory {
&&&&&&& private CarFactory() {&&&&&&& }
&&&&&&& public static Car makeNewCar(String carName, double carPrice) {&&&&&&&&&&& return new Car(carName, carPrice);&&&&&&& }
&&&&&&& public static Car makeNewCar() {&&&&&&&&&&& return new Car();&&&&&&& }&&& }
&&& /**&&&& * 第二个版本的生产者和消费者线程，加上了同步机制的方法&&&& * &&&& * @param args&&&& */&&& public static void main(String[] args) {&&&&&&& CarBigHouse bigHouse = new CarBigHouse();&&&&&&& new Thread(new CarSeller(bigHouse)).start();&&&&&&& new Thread(new Consumer(bigHouse)).start();&&& }
/ 采用Object类的wait和notify方法或者notifyAll方法（注意notify方法和notifyAll方法区别） // notify是唤醒其中一个在等待的线程。 // notifyAll是唤醒其他全部在等待的线程，但是至于哪个线程可以获得到锁还是要看竞争关系。线程状态：创建、运行、阻塞、销毁状态。（阻塞情况比较多，比如等待数据IO输入，阻塞了。）
代码如下:package com.jack.
import java.util.ArrayLimport java.util.Limport com.jack.thread.ThreadDemo4.CarBigHouse.C
/**&* 第二个版本的生产者消费者线程&* &* @author pinefantasy&* @since &*/public class ThreadDemo4 {
&&& /**&&&& * 姑且卖车的当做是生产者线程&&&& */&&& public static class CarSeller implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public CarSeller(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做生产者线程，往仓库里边增加汽车，其实是触发增加汽车&&&&&&&&&&&&&&& int count = bigHouse.put();&&&&&&&&&&&&&&& System.out.println("生产汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 姑且买车的人当做是消费者线程&&&& */&&& public static class Consumer implements Runnable {
&&&&&&& private CarBigHouse bigH
&&&&&&& public Consumer(CarBigHouse bigHouse) {&&&&&&&&&&& this.bigHouse = bigH&&&&&&& }
&&&&&&& @Override&&&&&&& public void run() {&&&&&&&&&&& for (int i = 0; i & 100; i++) {// 当做消费者线程，从仓库里边提取汽车，其实是触发，从仓库里边提取一辆汽车出来&&&&&&&&&&&&&&& int count = bigHouse.get();&&&&&&&&&&&&&&& System.out.println("消费汽车--&count = " + count);&&&&&&&&&&& }&&&&&&& }
&&& /**&&&& * 这边姑且当做是车子big house放车子的仓库房&&&& */&&& public static class CarBigHouse {
&&&&&&& public int carNums = 0;// 这边是仓库房子中车子的数量总数&&&&&&& public List&Car& carList = new ArrayList&Car&();// 这边模拟用来放汽车的list&&&&&&& public static final int max = 100;// 简单设置下，做下上限设置
&&&&&&& private Object lock = new Object();// 采用object的wait和notify方式处理同步问题
&&&&&&& public int put() {// 提供给生产者放汽车到仓库的接口&&&&&&&&&&& synchronized (lock) {&&&&&&&&&&&&&&& if (carList.size() == max) {// 达到了上限，不再生产car&&&&&&&&&&&&&&&&&&& try {&&&&&&&&&&&&&&&&&&&&&&& lock.wait();// 进行阻塞处理&&&&&&&&&&&&&&&&&&& } catch (InterruptedException e) {&&&&&&&&&&&&&&&&&&&&&&& e.printStackTrace();&&&&&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& Car car = CarFactory.makeNewCar();&&&&&&&&&&&&&&& carList.add(car);// 加到仓库中去&&&&&&&&&&&&&&& carNums++;// 总数增加1&&&&&&&&&&&&&&& lock.notify();// 唤醒等待的线程&&&&&&&&&&&&&&& return carN&&&&&&&&&&& }&&&&&&& }
&&&&&&& public int get() {// 提供给消费者从这边取汽车接口&&&&&&&&&&& Car car =&&&&&&&&&&& synchronized (lock) {&&&&&&&&&&&&&&& if (carList.size() == 0) {// 没有汽车可以用来消费&&&&&&&&&&&&&&&&&&& try {&&&&&&&&&&&&&&&&&&&&&&& lock.wait();&&&&&&&&&&&&&&&&&&& } catch (InterruptedException e) {&&&&&&&&&&&&&&&&&&&&&&& e.printStackTrace();&&&&&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& if (carList.size() != 0) {// size不为空才去取车&&&&&&&&&&&&&&&&&&& car = carList.get(carList.size() - 1);// 提取最后一个car&&&&&&&&&&&&&&&&&&& carList.remove(car);// 从从库list中移除掉&&&&&&&&&&&&&&&&&&& carNums--;// 总数减少1&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& lock.notify();&&&&&&&&&&&&&&& return carN&&&&&&&&&&& }&&&&&&& }
&&&&&&& public static class Car {
&&&&&&&&&&& public String carN// 汽车名称&&&&&&&&&&& public double carP// 汽车价格
&&&&&&&&&&& public Car() {&&&&&&&&&&& }
&&&&&&&&&&& public Car(String carName, double carPrice) {&&&&&&&&&&&&&&& this.carName = carN&&&&&&&&&&&&&&& this.carPrice = carP&&&&&&&&&&& }&&&&&&& }&&& }
&&& /**&&&& * 采用静态工厂方式创建car对象，这个只是简单模拟，不做设计模式上的过多考究&&&& */&&& public static class CarFactory {
&&&&&&& private CarFactory() {&&&&&&& }
&&&&&&& public static Car makeNewCar(String carName, double carPrice) {&&&&&&&&&&& return new Car(carName, carPrice);&&&&&&& }
&&&&&&& public static Car makeNewCar() {&&&&&&&&&&& return new Car();&&&&&&& }&&& }
&&& /**&&&& * 第二个版本的生产者和消费者线程，加上了同步机制的方法&&&& * &&&& * @param args&&&& */&&& public static void main(String[] args) {&&&&&&& CarBigHouse bigHouse = new CarBigHouse();&&&&&&& new Thread(new CarSeller(bigHouse)).start();&&&&&&& new Thread(new Consumer(bigHouse)).start();&&& }
您可能感兴趣的文章:
大家感兴趣的内容
12345678910
最近更新的内容
常用在线小工具