- 浏览: 304896 次
- 性别:
- 来自: 重庆
最新评论
-
HF_SKY000:
请问:
一、能否提供一下密钥库文件的生成方法?
二、密钥库的密 ...
Java sslSocket 聊天实例
文章列表
panel
- 博客分类:
- jquery-easyui-1.2.6
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html> <head> <!-- easyui的样式 --> <link rel="stylesheet" type="text/css" href="../js/jquery-easyui-1.3.1/themes/gray/easyui.css"> <!-- 小图标的样式 --> ...
l传统集合类在并发访问时的问题说明,见附件
l传统方式下用Collections工具类提供的synchronizedCollection方法来获得同步集合,分析该方法的实现源码。
l传统方式下的Collection在迭代集合时,不允许对集合进行修改。
Ø用空中网面试的同步级线程题进行演示
Ø根据AbstractList的checkForComodification方法的源码,分析产生ConcurrentModificationException异常的原因。
l什么是可阻塞队列,阻塞队列的作用与实际应用,阻塞队列的实现原理。
l阻塞队列与Semaphore有些相似,但也不同,阻塞队列是一方存放数据,另一方释放数据,Semaphore通常则是由同一方设置和释放信号量。
lArrayBlockingQueue
Ø只有put方法和take方法才具有阻塞功能
l用3个空间的队列来演示阻塞队列的功能和效果。
l用两个具有1个空间的队列来实现同步通知的功能。
public static void main(String[] args) { final BlockingQueue queue = new Arr ...
用于实现两个人之间的数据交换,每个人在完成一定的事务后想与对方交换数据,第一个先拿出数据的人将一直等待第二个人拿着数据到来时,才能彼此交换数据
public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final Exchanger exchanger = new Exchanger(); service.execute(new Runnable(){ public void run() { try {
St ...
CountDownLatch
- 博客分类:
- 多线程
Ø犹如倒计时计数器,调用CountDownLatch对象的countDown方法就将计数器减1,当计数到达0时,则所有等待者或单个等待者开始执行。这直接通过代码来说明CountDownLatch的作用,这样学员的理解效果更直接。
Ø可以实现一个人(也可以是多个人)等待其他所有人都来通知他,这犹如一个计划需要多个领导都签字后才能继续向下实施。还可以实现一个人通知多个人的效果,类似裁判一声口令,运动员同时开始奔跑。用这个功能做百米赛跑的游戏程序不错哦!
public static void main(String[] args) { ExecutorService ...
CyclicBarrier
- 博客分类:
- 多线程
lCyclicBarrier
表示大家彼此等待,大家集合好后才开始出发,分散活动后又在指定地点集合碰面,这就好比整个公司的人员利用周末时间集体郊游一样,先各自从家出发到公司集合后,再同时出发到公园游玩,在指定地点集合后再同时开始就餐,…。
public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final CyclicBarrier cb = new CyclicBarrier(3); for(int i=0;i<3; ...
Semaphore实现信号灯
- 博客分类:
- 多线程
lSemaphore可以维护当前访问自身的线程个数,并提供了同步机制。使用Semaphore可以控制同时访问资源的线程个数,例如,实现一个文件允许的并发访问数。
ØSemaphore实现的功能就类似厕所有5个坑,假如有十个人要上厕所, ...
Condition实现线程通信
- 博客分类:
- 多线程
在等待 Condition 时,允许发生“虚假唤醒”,这通常作为对基础平台语义的让步。对于大多数应用程序,这带来的实际影响很小,因为 Condition 应该总是在一个循环中被等待,并测试正被等待的状态声明。某个实现可以随意移除可能的虚假唤醒,但建议应用程序程序员总是假定这些虚假唤醒可能发生,因此总是在一个循环中等待。
一个锁内部可以有多个Condition,即有多路等待和通知,可以参看jdk1.5提供的Lock与Condition实现的可阻塞队列的应用案例,从中除了要体味算法,还要体味面向对象的封装。在传统的线程机制中一个监视器对象上只能有一路等待和通知,要想实现多路等待和通知,必须 ...
Lock实现线程通信
- 博客分类:
- 多线程
Lock比传统线程模型中的synchronized方式更加面向对象,与生活中的锁类似,锁本身也应该是一个对象。两个线程执行的代码片段要实现同步互斥的效果,它们必须用同一个Lock对象。
读写锁:分为读锁和写锁,多个读锁不互斥,读锁与写锁互斥,写锁与写锁互斥,这是由jvm自己控制的,你只要上好相应的锁即可。如果你的代码只读数据,可以很多人同时读,但不能同时写,那就上读锁;如果你的代码修改数据,只能有一个人在写,且不能同时读取,那就上写锁。总之,读的时候上读锁,写的时候上写锁!
public static void main(String[] args) { new ...
/** * Future和Callable的使用 */ public static void main(String[] args) { ExecutorService service = Executors.newSingleThreadExecutor(); Future<String> future = service.submit(new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); ...
//线程池
public static void main(String[] args) { //ExecutorService service = Executors.newFixedThreadPool(3); //在线程池中创建一个线程,这个线程死了,会马上创建一个新的线程 //ExecutorService service = Executors.newSingleThreadExecutor(); ExecutorService service = Executors.newCachedThreadPool(); for (int i = 1; i <= 1 ...
ThreadLocal的使用
- 博客分类:
- 多线程
public class ThreadLocalTest { private static ThreadLocal<Integer> x = new ThreadLocal<Integer>(); private static ThreadLocal<MyThreadScopeData> myThreadScopeData = new ThreadLocal<MyThreadScopeData>(); public static void main(String[] args) { for (int i = 0; i < ...
public class TraditionalThreadCommunication { public static void main(String[] args) { final Business business = new Business(); new Thread() { @Override public void run() { for (int i = 1; i <= 50; i++) { ...
public class TraditionalSychronized { /** * @param args */ public static void main(String[] args) { new TraditionalSychronized().init(); } public void init() { final Printer printer = new Printer(); new Thread() { ...
传统多线程的创建方法
- 博客分类:
- 多线程
/** * @param 传统的线程的两张创建方法 */ public static void main(String[] args) { Thread thread = new Thread() { @Override public void run() { while (true) { try { Thread. ...