文档章节

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

业余编程人士
 业余编程人士
发布于 2017/07/08 16:14
字数 1059
阅读 12
收藏 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();  
    }  

 

© 著作权归作者所有

共有 人打赏支持
业余编程人士
粉丝 4
博文 19
码字总数 9137
作品 0
其他
程序员
私信 提问
高性能产品的必由之路—性能测试工具

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

fdhay
2016/09/13
47
0
深入剖析企业级数据安全性加密、解密算法体系实战汇总

资源下载链接-https://pan.baidu.com/s/1mhZY9mC 密码: 6wrg 目前很多企业应用领域的架构师都很关注加密与解密算法在应用中的使用,譬如用户密码加密、网络协议加密等。如何在名目繁多的Jav...

huanyingmous
2017/08/28
13
0
Linux编程学习:Linux运维必会的系统工具

×××教育,独家开创“Linux云计算架构师课程”。这是独家的全栈Linux运维课程,包含“公有云+私有云+自动化运维+Python运维开发”等核心开发技术,其中“私有云课程”较同行最全。而值得注...

长沙千锋
04/25
0
0
我们在谈高并发、分布式,其实都在谈什么?

2018年,互联网行业风起云涌,IT工程师如果仅凭传统开发思维,无法突破固有知识体系,终将会被社会所淘汰。既需要掌控整体又需要洞悉局部瓶颈并依据具体的业务场景给出解决方案的领导型人物—...

技术琐话
06/20
0
0
原来这样做,才能向架构师靠近

说在前面:达人课是GitChat的一款轻阅读产品,由特约讲师独家发布。每一个课程你都可获得6-12篇的深度文章,同时可在读者圈与讲师互动交流。GitChat达人课,让技术分享更简单。进入我的GitCh...

gitchat
2017/11/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

搬瓦工DC3机房和DC8机房哪个速度快,应该选哪个?

搬瓦工DC3机房和DC8机房都是搬瓦工CN2,那么这两个机房比较哪个机房速度快?搬瓦工DC3机房和DC8机房应该选择哪个机房?移动用户用DC8机房还是DC3机房?联通用DC3还是DC8快?电信应该选DC3还是...

Alanbrooke
33分钟前
1
0
探秘Runtime - Runtime介绍

该文章属于<简书 — 刘小壮>原创,转载请注明: <简书 — 刘小壮> https://www.jianshu.com/p/ce97c66027cd Runtime是iOS系统中重要的组成部分,面试也是必问的问题,所以Runtime是一个iOS工...

刘小壮
34分钟前
1
0
图形用户界面和交互输入方法---小结

中国龙-扬科
50分钟前
1
0
当程序员有了中年危机 你会发现你就是个屁

前言 程序员是一个怎样的存在?引用一句鸡汤的名言来说:你以为你用双手改变了世界,实际上是苍老了自己。为什么我今天会抛出这个话题,其实我也是一个懵懂的少年,我也曾经为了成为一名程序...

架构师springboot
今天
13
0
大型网站B2C商城项目实战+MongoDB+Redis+zookeeper+MySQL

本文列出了当今计算机软件开发和应用领域最关键部分,如果你想保证你现在以及未来的几年不失业,那么你最好跟上这些技术的发展。虽然你不必对这十种技术样样精通,但至少应该对它们非常熟悉。...

java知识分子
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部