java.util.concurrent包的并发处理

《java.util.concurrent包的并发处理》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、浅谈java.util.concurrent包的并发处理收藏新一篇: 国耻日-永远的1937年12月13日，悼念反人类的南京大屠杀七十周年我们都知道，在JDK1.5之前，Java中要进行业务并发时，通常需要有程序员独立完成代码实现，而当针对高质量Java多线程并发程序设计时,为防止死蹦等现象的出现，比如使用java之前的wait()、notify()和synchronized等，每每需要考虑性能、死锁、公平性、资源管理以及如何避免线程安全性方面带来的危害等诸多因素，往往会采用一些较为复杂的安全策略，加重了程序员的开发负担.

2、万幸的是，在JDK1.5出现之后，Sun大神终于为我们这些可怜的小程序员推出了java.util.concurrent工具包以简化并发完成。开发者们借助于此，将有效的减少竞争条件（raceconditions）和死锁线程。concurrent包很好的解决了这些问题，为我们提供了更实用的并发程序模型。java.util.concurrent下主要的接口和类：Executor：具体Runnable任务的执行者。ExecutorService:一个线程池管理者，其实现类有多种，比如普通线程池，定时调度线程池ScheduledEx

3、ecutorService等，我们能把一个Runnable,Callable提交到池中让其调度。Future：是与Runnable,Callable进行交互的接口，比如一个线程执行结束后取返回的结果等等，还提供了cancel终止线程。BlockingQueue：阻塞队列。下面我写一个简单的事例程序：FutureProxy.javapackage org.test.concurrent;/** *//** * 

Title: LoonFramework

Description:利用Future模式进行处

4、理

Copyright: Copyright (c) 2007

Company: LoonFramework

5、a.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;import java.util.concurrent.ThreadFactory;public abstract class FutureProxy ...{    private final class CallableImpl 

6、implements Callable ...{        public T call() throws Exception ...{            return FutureProxy.this.createInstance();        }    }    private static class InvocationHandlerImpl implements InvocationHandler ...{        private Future future;         

7、       private volatile T instance;                InvocationHandlerImpl(Future future)...{            this.future = future;        }                public Object invoke(Object proxy, Method method, Object[] args)                throws Throwable ...{           

8、 synchronized(this)...{                if(this.future.isDone())...{                    this.instance = this.future.get();                }else...{