Android中使用CountDownLatch并发多线程操作
2012-12-25 21:30
1266 查看
Java的concurrent包里面的CountDownLatch其实可以把它看作一个计数器,只不过这个计数器的操作是原子操作,同时只能有一个线程去操作这个计数器,也就是同时只能有一个线程去减这个计数器里面的值。
你可以向CountDownLatch对象设置一个初始的数字作为计数值,任何调用这个对象上的await()方法都会阻塞,直到这个计数器的计数值被其他的线程减为0为止。
CountDownLatch的一个非常典型的应用场景是:有一个任务想要往下执行,但必须要等到其他的任务执行完毕后才可以继续往下执行。假如我们这个想要继续往下执行的任务调用一个CountDownLatch对象的await()方法,其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法,这个调用await()方法的任务将一直阻塞等待,直到这个CountDownLatch对象的计数值减到0为止。
在Android当中使用CountDownLatch要注意一点,即,需要另外新建一个线程监视工作线程,否则会ANR错误。代码如下:
你可以向CountDownLatch对象设置一个初始的数字作为计数值,任何调用这个对象上的await()方法都会阻塞,直到这个计数器的计数值被其他的线程减为0为止。
CountDownLatch的一个非常典型的应用场景是:有一个任务想要往下执行,但必须要等到其他的任务执行完毕后才可以继续往下执行。假如我们这个想要继续往下执行的任务调用一个CountDownLatch对象的await()方法,其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法,这个调用await()方法的任务将一直阻塞等待,直到这个CountDownLatch对象的计数值减到0为止。
在Android当中使用CountDownLatch要注意一点,即,需要另外新建一个线程监视工作线程,否则会ANR错误。代码如下:
package com.example.test; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.util.Log; /** * * @Title: MainActivity.java * @Package com.example.test * @Description: Android当中使用CountDownLatch * @author Yang * @date 2012-12-25 下午9:30:57 * @version V1.0 */ public class MainActivity extends Activity { private DatePickerFragment fragment; @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); testCountDownLatch(); } private void testCountDownLatch() { LightProgressDialog.create(MainActivity.this, "Test"); final Handler handler = new Handler() { public void handleMessage(Message msg) { if (msg.what == 1){ LightProgressDialog.cancelDialog(); Log.d("MainActivity","========================SUCESS========================"); } } }; new Thread() { public void run() { CountDownLatch latch = new CountDownLatch(2);// 设置计数值, ExecutorService exec = Executors.newCachedThreadPool();// 创建线程池 exec.execute(new TestRunable1(latch)); exec.execute(new TestRunable2(latch)); try { latch.await();// 等待所有线程完成操作 } catch (InterruptedException e) { e.printStackTrace(); } handler.sendEmptyMessage(1); exec.shutdown(); }; }.start(); } class TestRunable1 implements Runnable { private CountDownLatch latch; public TestRunable1(CountDownLatch latch) { super(); this.latch = latch; } @Override public void run() { try { Thread.sleep(1000 * 5); } catch (InterruptedException e) { e.printStackTrace(); } latch.countDown(); } } class TestRunable2 implements Runnable { private CountDownLatch latch; public TestRunable2(CountDownLatch latch) { super(); this.latch = latch; } @Override public void run() { try { Thread.sleep(1000 * 3); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } } } }
相关文章推荐
- Java并发Concurrent包的锁(六)——CountDownLatch源码分析及使用
- Java/Android多线程并发、同步,线程之间通信,主、子线程的一些问题(CountDownLatch、CyclicBarrier和Semaphore)
- Java并发编程之2——同步工具类的使用(CountDownLatch,CyclicBarrier,BlockungQueue,Semaphore)
- Android 并发二三事之利用CountDownLatch 或 ConditionVariable实现自定义Future
- Java并发之CountDownLatch的使用
- Java中的并发工具CountDownLatch、CyclicBarrier、Semapphore使用详解
- java并发包里CountDownLatch的使用详解
- 使用Java辅助类(CountDownLatch、CyclicBarrier、Semaphore)并发编程
- 多线程并发常用类:condition,semaphore,CyclicBarrier,countdownlatch,exchanger使用整理
- Java并发编程:CountDownLatch的使用以及一个容易踩到的陷阱
- Java 并发编程实战学习笔记——CountDownLatch的使用
- Java并发之CountDownLatch的使用和源码解析
- Android CountDownLatch的使用
- Java并发基础(五)-CountDownLatch、CyclocBarrier、Phaser的使用
- [Java并发]使用CountDownLatch和CyclicBarrier等待多线程完成
- java并发中CountDownLatch的使用示例
- java并发编程之CountDownLatch
- Java并发之CountDownLatch、CyclicBarrier和Semaphore
- Java之CountDownLatch使用
- 什么时候使用CountDownLatch(zookeeper分布式锁中用过)