文档章节

架构师课程 - 3 Util.Concurrent下的工具类

业余编程人士
 业余编程人士
发布于 2017/07/08 16:14
字数 1059
阅读 41
收藏 0

CountDownLatch : 监听某些初始化操作 初始化完成后 通知主线程继续工作,比如zookeeper,在开始的时候开始web要先连接一下,初始化一些实例,因此要等连接真正成功了才能初始化,所以可以用countDownLatch来监控。

        final CountDownLatch countDown = new CountDownLatch(2);
		
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("进入线程t1" + "等待其他线程处理完成...");
					countDown.await(); 
             // 等待阻塞在这里了,因为 new CountDownLatch(2)所有如果有两个线程发出countDown的时候 此线程继续
					System.out.println("t1线程继续执行...");
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		},"t1");
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t2线程进行初始化操作...");
					Thread.sleep(3000); // 睡眠
					System.out.println("t2线程初始化完毕,通知t1线程继续...");
					countDown.countDown(); // 发出一个countDown信号
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		Thread t3 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t3线程进行初始化操作...");
					Thread.sleep(4000);
					System.out.println("t3线程初始化完毕,通知t1线程继续...");
					countDown.countDown(); // 发出一个countDown信号
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		
		t1.start();
		t2.start();
		t3.start();

CyclicBarrier: 每一个线程都要准备好才出发,只要有一个没准备好久都等待。多用于多台机器同一时间要执行任务时使用

static class Runner implements Runnable {  
	    private CyclicBarrier barrier;  
	    private String name;  
	    
	    public Runner(CyclicBarrier barrier, String name) {  
	        this.barrier = barrier;  
	        this.name = name;  
	    }  
	    @Override  
	    public void run() {  
	        try {  
	            Thread.sleep(1000 * (new Random()).nextInt(5));  
	            System.out.println(name + " 准备OK.");  
	            barrier.await();  // 等待,new CyclicBarrier(3) 三个运动员都准备好才放行,调用await三次
	        } catch (InterruptedException e) {  
	            e.printStackTrace();  
	        } catch (BrokenBarrierException e) {  
	            e.printStackTrace();  
	        }  
	        System.out.println(name + " Go!!");  
	    }  
	} 
	
    public static void main(String[] args) throws IOException, InterruptedException {  
        CyclicBarrier barrier = new CyclicBarrier(3);  // 3 
        ExecutorService executor = Executors.newFixedThreadPool(3);  
        
        executor.submit(new Thread(new Runner(barrier, "zhangsan")));  
        executor.submit(new Thread(new Runner(barrier, "lisi")));  
        executor.submit(new Thread(new Runner(barrier, "wangwu")));  
  
        executor.shutdown();  
    }  

CountDownlatch 是一个线程等待其他N各线程等待给我发通知 然后一个线程运行

CyclicBarrier 是多个等待互相等待 多个运行。

Callable/Future: 适用于耗时时间长。

private String para;
	
	public UseFuture(String para){
		this.para = para;
	}
	
	/**
	 * 这里是真实的业务逻辑,其执行可能很慢
	 */
	@Override
	public String call() throws Exception {
		//模拟执行耗时
		Thread.sleep(5000);
		String result = this.para + "处理完成";
		return result;
	}
	
	//主控制函数
	public static void main(String[] args) throws Exception {
		String queryStr = "query";
		//构造FutureTask,并且传入需要真正进行业务逻辑处理的类,该类一定是实现了Callable接口的类
		FutureTask<String> future = new FutureTask<String>(new UseFuture(queryStr));
		
		FutureTask<String> future2 = new FutureTask<String>(new UseFuture(queryStr));
		//创建一个固定线程的线程池且线程数为1,
		ExecutorService executor = Executors.newFixedThreadPool(2);
		//这里提交任务future,则开启线程执行RealData的call()方法执行
		//submit和execute的区别: 第一点是submit可以传入实现Callable接口的实例对象, 第二点是submit方法有返回值
		
		Future f1 = executor.submit(future);		//单独启动一个线程去执行的,线程池开的一个,非主线程
		Future f2 = executor.submit(future2);
		System.out.println("请求完毕");
		
		try {
			//这里可以做额外的数据操作,也就是主程序执行其他业务逻辑
			System.out.println("处理实际的业务逻辑...");
			Thread.sleep(1000);
		} catch (Exception e) {
			e.printStackTrace();
		}
		//调用获取数据方法,如果call()方法没有执行完成,则依然会进行等待,FutureTask是异步的。aaa先打印 future的数据后打印
		System.out.println("数据:" + future.get());
		System.out.println("数据:" + future2.get());
        System.out.println("aaa");
		
		executor.shutdown();
	}

Semaphore : 信号量适合高并发,许可进入票,限流 不过一般不推荐这样 ,因为这样效率低。

PV(page view) 网站总访问量,刷一次记一次 ,

UV (unique visitor):一个IP只记录一次

QPS(query per second): 每秒查询数,一次查询可能有好多query,可能根据这个参数看一下是否繁忙。会记录日志, 之后调优数据库 服务器等。

RT (response time): 请求相应时间。

  // 线程池  
        ExecutorService exec = Executors.newCachedThreadPool();  
        // 只能5个线程同时访问  
        final Semaphore semp = new Semaphore(5);  
        // 模拟20个客户端访问  
        for (int index = 0; index < 20; index++) {  
            final int NO = index;  
            Runnable run = new Runnable() {  
                public void run() {  
                    try {  
                        // 获取许可,只有5个线程可以进来,有一个空位 别的才能进来 ,做到限流。
                        semp.acquire();  
                        System.out.println("Accessing: " + NO);  
                        //模拟实际业务逻辑
                        Thread.sleep((long) (Math.random() * 10000));  
                        // 访问完后,释放  
                        semp.release();  
                    } catch (InterruptedException e) {  
                    }  
                }  
            };  
            exec.execute(run);  
        } 
        
        try {
			Thread.sleep(10);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
        
        //System.out.println(semp.getQueueLength());
        
        
        
        // 退出线程池  
        exec.shutdown();  
    }  

 

© 著作权归作者所有

业余编程人士
粉丝 5
博文 19
码字总数 9137
作品 0
其他
程序员
私信 提问
加载中

评论(0)

Spring Boot入门系列(七)Spring Boot整合Redis缓存

前面介绍了Spring Boot 中的整合Mybatis并实现增删改查,。不清楚的朋友可以看看之前的文章:https://www.cnblogs.com/zhangweizhong/category/1657780.html。 今天主要讲解Springboot整合R...

章为忠
03/18
0
0
SpringBoot入门系列(二)如何返回统一的数据格式

前面介绍了Spring Boot的优点,然后介绍了如何快速创建Spring Boot 项目。不清楚的朋友可以看看之前的文章:https://www.cnblogs.com/zhangweizhong/category/1657780.html。 今天来说一说S...

章为忠
03/04
0
0
下载系统架构设计:从程序员向架构师转型

系统架构设计:从程序员向架构师转型 地址:http://pan.baidu.com/s/1o7OZJQU 密码:jyiu 本课程首先围绕普通开发人员如何向架构师转型这一课题,从架构师的角色以及转型过程中会遇到的困难及其...

听半的曲
2019/07/17
0
0
SpringBoot入门系列(三)资源文件属性配置

前面介绍了Spring的@Controller和@RestController控制器, 他们是如何响应客户端请求,如何返回json数据。不清楚的朋友可以看看之前的文章:https://www.cnblogs.com/zhangweizhong/categor...

章为忠
03/06
0
0
高性能产品的必由之路—性能测试工具

简介:开发人员如果具备了性能测试和性能优化的技能,在成长为架构师的路上会更加有竞争力。本门课程以Jmeter为中心给大家介绍了最最常用的性能测试的工具,通过对不同类型的系统进行性能测试...

fdhay
2016/09/13
107
0

没有更多内容

加载失败,请刷新页面

加载更多

这个曾和 SpaceX 旗鼓相当的明星公司,如何走到了破产边缘?

摘要 昔日风光无限的 OneWeb,正在听候命运裁决。 眼下,率先规划低轨宽带卫星星座的 OneWeb,或将准备提前「离轨」了。 北京时间 3 月 28 日,由软银参与投资的卫星运营商 OneWeb 宣布申请破...

osc_s2b5kacl
29分钟前
49
0
云终端选购指南,需要认准这三点

随着大数据和云计算的快速发展,云桌面开始被越来越多的客户所接受,而随着云桌面的兴起,云终端作为云桌面的一个重要组成部分也开始被越来越多的用所使用的,特别是近几年来,市场上更是出现...

GZASD
30分钟前
29
0
讨厌数学的我,竟然在 VR 游戏里听老外讲了一堂数学课

摘要 今年最火的 VR 游戏被这个老师当成了教学现场。 数学和物理曾经是我最害怕的两门课,我不知道有多少人和我一样看到那些奇怪的公式就会头疼冒汗,毕业之后,很多数学知识早已还给了老师,...

osc_facwbzof
30分钟前
38
0
第四章:Linux文件及目录管理命令基础(三)

补充 /etc/hostname :CenOS7主机名配置文件 [root@oldboyedu ~]# cat /etc/hostname oldboyedu /etc/sysconfig/network C6主机名配置文件 [root@oldboy ~]# cat /etc/sysconfig/network......

osc_3ubtokn0
32分钟前
24
0
如何为React Redux应用程序,创建可编辑的数据网格(二)

近日,前端开发工具包 WijmoJS 发布最新版本,将所有组件和功能模块化,更加体现出 WijmoJS 的小巧、灵活和高效。这一版本的最大亮点,就是增加了“可在React Redux 应用程序中,编辑数据网格...

葡萄城技术团队
32分钟前
24
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部