`
文章列表

panel

 <!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 ...

Exchanger

用于实现两个人之间的数据交换,每个人在完成一定的事务后想与对方交换数据,第一个先拿出数据的人将一直等待第二个人拿着数据到来时,才能彼此交换数据   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; ...
  lSemaphore可以维护当前访问自身的线程个数,并提供了同步机制。使用Semaphore可以控制同时访问资源的线程个数,例如,实现一个文件允许的并发访问数。 ØSemaphore实现的功能就类似厕所有5个坑,假如有十个人要上厕所, ...
在等待 Condition 时,允许发生“虚假唤醒”,这通常作为对基础平台语义的让步。对于大多数应用程序,这带来的实际影响很小,因为 Condition 应该总是在一个循环中被等待,并测试正被等待的状态声明。某个实现可以随意移除可能的虚假唤醒,但建议应用程序程序员总是假定这些虚假唤醒可能发生,因此总是在一个循环中等待。 一个锁内部可以有多个Condition,即有多路等待和通知,可以参看jdk1.5提供的Lock与Condition实现的可阻塞队列的应用案例,从中除了要体味算法,还要体味面向对象的封装。在传统的线程机制中一个监视器对象上只能有一路等待和通知,要想实现多路等待和通知,必须 ...
 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 ...
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. ...
Global site tag (gtag.js) - Google Analytics