- 浏览: 56572 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
shifulong:
cywhoyi 写道现在用Javassist代理也不错的看了一 ...
java动态代理(jdk &cglib) -
cywhoyi:
现在用Javassist代理也不错的
java动态代理(jdk &cglib)
Java 7的并发包中推出了Phaser,其功能跟CyclicBarrier和CountDownLatch有些重叠,但是提供了更灵活的用法,例如支持动态调整注册任务的数量等
别人的牛逼的blok: http://whitesock.iteye.com/blog/1135457
结果如下
start
a a a b b b b b b b b b b a a a a a a a c c c c c c c c c c
======phase : 0 , parties : 4============分割线========================
f d f e e e e e e e e e e f d f d f d d d d d d d f f f f f
======phase : 1 , parties : 4============分割线========================
i i i i i i i i i i g g g g g g g g g g h h h h h h h h h h
======phase : 2 , parties : 4============分割线========================
k k k k k l j j l k l j l k k k l l l l l l j k j j j j j j
======phase : 3 , parties : 4============分割线========================
m m m m m m m o n o m o o o o o n n n n n n o o o m n n n m
======phase : 4 , parties : 4============分割线========================
p q q q q q q q q q q r p r p r p r p p p r p r p p r r r r
======phase : 5 , parties : 4============分割线========================
u s s s t s s s u s t s u s s t u t u t u t u t u u u t t t
======phase : 6 , parties : 4============分割线========================
w w w w w w w w w w v x x x x x x x x x x v v v v v v v v v
======phase : 7 , parties : 3============分割线========================
y y z z z y z y z z z z z z y y y y y y
======phase : 8 , parties : 1============分割线========================
end
别人的牛逼的blok: http://whitesock.iteye.com/blog/1135457
package com.test.uuu; import java.util.concurrent.Phaser; /** * Phaser:阶段的意思 * 有两个概念:phase & party ,phase 表明当前执行的阶段,party当前注册了的线程数量 * <p/> * 创建三个线程分别打印从'a'开始的的字母表,每个字母打印十次, * 三个线程打印完之后在继续打印,知道26个字母打印完 * 打印结果如下 */ public class PhaserTest { public static void main(String[] args) { System.out.println("start"); Phaser phaser = new Phaser(3) { //1. return true -> parser就会终止 //2. 每一个阶段执行完都会调用onAdvance @Override protected boolean onAdvance(int phase, int registeredParties) { System.out.printf("\n======phase : %s , parties : %s============分割线========================\n", phase, registeredParties); return registeredParties == 1; // 表示parser注册的线程数为1的时候终止parser // return phase >=3; //表示执行完第四阶段就会终止parser } }; //PhaserTest.PhaserThread s = new PhaserTest().new PhaserThread('c',null); for (int i = 0; i < 3; i++) { //顺便复习下 内部类 和 静态内部类 初始化的知识 new Thread(new PhaserTest().new PhaserThread((char) ('a' + i), phaser)).start(); } //主线程注册到phaser中 phaser.register(); while (!phaser.isTerminated()) { phaser.arriveAndAwaitAdvance(); } System.out.println("end"); } class PhaserThread implements Runnable { private char letter; private Phaser phaser; public PhaserThread(char letter, Phaser phaser) { this.letter = letter; this.phaser = phaser; } public void run() { while (!phaser.isTerminated()) { for (int i = 0; i < 10; i++) { System.out.print(letter + " "); } letter = (char) (letter + 3); if (letter > 'z') { //取消当前线程的注册 phaser.arriveAndDeregister(); break; } else { //执行完当前阶段,等待下一阶段 phaser.arriveAndAwaitAdvance(); } } } } }
结果如下
start
a a a b b b b b b b b b b a a a a a a a c c c c c c c c c c
======phase : 0 , parties : 4============分割线========================
f d f e e e e e e e e e e f d f d f d d d d d d d f f f f f
======phase : 1 , parties : 4============分割线========================
i i i i i i i i i i g g g g g g g g g g h h h h h h h h h h
======phase : 2 , parties : 4============分割线========================
k k k k k l j j l k l j l k k k l l l l l l j k j j j j j j
======phase : 3 , parties : 4============分割线========================
m m m m m m m o n o m o o o o o n n n n n n o o o m n n n m
======phase : 4 , parties : 4============分割线========================
p q q q q q q q q q q r p r p r p r p p p r p r p p r r r r
======phase : 5 , parties : 4============分割线========================
u s s s t s s s u s t s u s s t u t u t u t u t u u u t t t
======phase : 6 , parties : 4============分割线========================
w w w w w w w w w w v x x x x x x x x x x v v v v v v v v v
======phase : 7 , parties : 3============分割线========================
y y z z z y z y z z z z z z y y y y y y
======phase : 8 , parties : 1============分割线========================
end
发表评论
-
test
2016-02-26 17:45 430http://c.hiphotos.baidu.com/t ... -
java Integer的比较
2016-01-18 20:09 1029/** * A constant ... -
load过高排查
2016-01-07 19:15 1088jstack 线程的运行情况、线程的状态 load过高的 ... -
Runnable Callable Future FutrueTask ExecutorService的关系
2015-11-30 16:34 660public interface ExecutorSe ... -
单例模式以及序列化仍然单例的问题
2015-11-18 10:47 552这种方式仍然存在并发的同步阻塞问题,并且jdk1.5之 ... -
linux5种网络IO模型
2015-11-07 21:58 856看网上书上的各种解释太绕口难理解了,看到个例子挺好的。 ... -
nio学习记录 : start(buffer channel selector)
2015-11-06 22:17 725Buffer的capacity,limit,positio ... -
desgn partten : 适配器&门面
2015-11-05 11:55 533adapter adapter 一个接口转换成另一个接 ... -
java泛型中的PECS
2015-10-26 17:58 977extends List<? extends Nu ... -
spring自定义cache
2015-10-21 17:14 4509下面是一个较为详细的spring缓存的介绍 http:/ ... -
spring各种接口的作用FactoryBean、ApplicationContextAware、InitializingBean
2015-10-20 20:04 3007FactoryBean 当配置文件中<bean&g ... -
jvm调试命令
2015-10-14 15:42 464jps jps -mlv 列出当前jvm进程 ji ... -
CAS自定义线程安全的计数器
2015-10-10 17:36 2157写了一个线程安全的计数器(用锁显得多没有水平),非阻塞的,通过 ... -
java线程遇见的一个小问题(本质和线程无关都是基础知识)
2015-09-21 10:29 523猜猜下面几个程序,那个是线程安全的 NO1 public cl ... -
JUC--Exchanger
2015-09-07 17:26 858Exchanger 用于线程之间数据交换,通过exchange ... -
java浮点型float遇到的一点问题
2015-04-10 16:32 643float 可以除以0,还可以不是一个数字 即Float.is ... -
java静态块的一个小坑
2015-04-07 18:26 597public class Student { pr ... -
java学习计划
2015-04-07 17:57 372刚入职的时候,team大神给制定的学习计划。 受益匪浅啊 ... -
购物网站(spring+mybatis+velocity+maven)项目
2015-04-03 18:06 951原文地址: http://www.iteye.com/top ... -
synchronized与static synchronized 的区别
2015-03-25 18:51 679基本上每个面试都问到了,面试命中率很大。 public cl ...
相关推荐
并发编程代码demo
heima-JUC-资料
juc-1(2).docx
Java 多线程与并发(7_26)-JUC - 类汇总和学习指南
尚硅谷周阳老师的juc课程
学习狂神说的juc编程的笔记
juc-jenkins-2018 JUC Jenkins 2018演示源代码 先决条件 为了运行此演示,必须有一个有效的JDK,git命令以及curl。 克隆存储库 将此存储库克隆到您家中的某个位置: git clone ...
互联网大厂开发高频面试及知识点总结 涉及JUC 包下的并发相关知识梳理 JVM及参数调优案例等
来自B站 遇见狂神说
java.util.concurrent、linux基本操作、NIO(同步、非阻塞)-Channel(通道)、Buffer(缓冲区)、Selector(选择器)
juc-demo JUC包下常用工具练习Demo 内容: 1、Semaphore 2、CountDownLatch 3、CyclicBarrier 4、ReentrantLock + Condition实现阻塞队列 Created by @minghui.y.
juc-learn:juc相关源码的分析以及使用介绍
JUC线程高级,
联合会 多线程与高并发
教程视频:在 Java 5.0 提供了 java.util.concurrent(简称JUC)包,在此包中增加了在并发编程中很常用的工具类, 用于定义类似于线程的自定义子系统,包括线程池,异步 IO 和轻量级任务框架;还提供了设计用于多线程上下文...
一个java的多线程juc总结,其中包含基础知识,现成的状态图,关于synchronized,线程优先级和线程分类,interrupt、interupted、isInterrupted的使用,sleep、yield、join的详细使用,锁和等待池介绍。
江苏大学计组课设指令编写
快速排序(程序).txt快速排序(程序).txt快速排序(程序).txt快速排序(程序).txt快速排序(程序).txt
JUC、JMM核心知识点笔记 尚硅谷周阳老师课程——笔记。 / / JUC知识点 JMM volatile关键字 可见性 原子性 有序性 哪些地方用到过volatile? 单例模式的安全问题 CAS CAS底层原理 CAS缺点 ABA问题 AtomicReference ...
指数同步和可重入锁类对象锁列出高并发设置高并发映射高并发可调用的界面