?
?
我們都知道，在JDK1.5之前，Java中要進行業務并發時，通常需要有程序員獨立完成代碼實現，而當針對高質量Java多線程并發程序設計時,為防止死蹦等現象的出現，比如使用java之前的wait()、notify()和synchronized等，每每需要考慮性能、死鎖、公平性、資源管理以及如何避免線程安全性方面帶來的危害等諸多因素，往往會采用一些較為復雜的安全策略，加重了程序員的開發負擔.萬幸的是，在JDK1.5出現之后，Sun大神終于為我們這些可憐的小程序員推出了java.util.concurrent工具包以簡化并發完成。開發者們借助于此，將有效的減少競爭條件（race conditions）和死鎖線程。concurrent包很好的解決了這些問題，為我們提供了更實用的并發程序模型。
java.util.concurrent下主要的接口和類：
Executor：具體Runnable任務的執行者。
ExecutorService:一個線程池管理者，其實現類有多種，比如普通線程池，定時調度線程池ScheduledExecutorService等，我們能把一個
Runnable,Callable提交到池中讓其調度。
Future：是與Runnable,Callable進行交互的接口，比如一個線程執行結束后取返回的結果等等，還提供了cancel終止線程。
BlockingQueue：阻塞隊列。
下面我寫一個簡單的事例程序：
FutureProxy .java
java.util.concurrent下主要的接口和類：
Executor：具體Runnable任務的執行者。
ExecutorService:一個線程池管理者，其實現類有多種，比如普通線程池，定時調度線程池ScheduledExecutorService等，我們能把一個
Runnable,Callable提交到池中讓其調度。
Future：是與Runnable,Callable進行交互的接口，比如一個線程執行結束后取返回的結果等等，還提供了cancel終止線程。
BlockingQueue：阻塞隊列。
下面我寫一個簡單的事例程序：
FutureProxy .java
package
?org.test.concurrent;
/**
?*?<p>Title:?LoonFramework</p>
?*?<p>Description:利用Future模式進行處理</p>
?*?<p>Copyright:?Copyright?(c)?2007</p>
?*?<p>Company:?LoonFramework</p>
?*?
@author
?chenpeng??
?*?@email：ceponline@yahoo.com.cn?
?*?
@version
?0.1
?
*/
import
?java.lang.reflect.InvocationHandler;
import
?java.lang.reflect.Method;
import
?java.lang.reflect.Proxy;
import
?java.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
<
T
>
?
{
????
private
?
final
?
class
?CallableImpl?
implements
?Callable
<
T
>
?
{
????
????????
public
?T?call()?
throws
?Exception?
{
????????????
return
?FutureProxy.
this
.createInstance();
????????}
????}
????
private
?
static
?
class
?InvocationHandlerImpl
<
T
>
?
implements
?InvocationHandler?
{
????????
private
?Future
<
T
>
?future;
????????
????????
private
?
volatile
?T?instance;
????????
????????InvocationHandlerImpl(Future
<
T
>
?future)
{
????????????
this
.future?
=
?future;
????????}
????????
????????
public
?Object?invoke(Object?proxy,?Method?method,?Object[]?args)
????????????????
throws
?Throwable?
{
????????????
synchronized
(
this
)
{
????????????????
if
(
this
.future.isDone())
{
????????????????????
this
.instance?
=
?
this
.future.get();
????????????????}
else
{
????????????????????
while
(
!
this
.future.isDone())
{
????????????????????????
try
{
????????????????????????????
this
.instance?
=
?
this
.future.get();
????????????????????????}
catch
(InterruptedException?e)
{
????????????????????????????Thread.currentThread().interrupt();
????????????????????????}
????????????????????}
????????????????}
????????????????
????????????????
return
?method.invoke(
this
.instance,?args);
????????????}
????????}
????}
????
/**
?????*?實現java.util.concurrent.ThreadFactory接口
?????*?
@author
?chenpeng
?????*
?????
*/
????
private
?
static
?
final
?
class
?ThreadFactoryImpl?
implements
?ThreadFactory?
{
????????
public
?Thread?newThread(Runnable?r)?
{
????????????Thread?thread?
=
?
new
?Thread(r);
????????????thread.setDaemon(
true
);
????????????
return
?thread;
????????}
????}
????
private
?
static
?ExecutorService?service?
=
?Executors.newCachedThreadPool(
new
?ThreadFactoryImpl());
????
protected
?
abstract
?T?createInstance();
????
protected
?
abstract
?Class
<?
?
extends
?T
>
?getInterface();
????
????
/**
?????*?返回代理的實例
?????*?
@return
?????
*/
????@SuppressWarnings(
"
unchecked
"
)
????
public
?
final
?T?getProxyInstance()?
{
????????Class
<?
?
extends
?T
>
?interfaceClass?
=
?
this
.getInterface();
????????
if
?(interfaceClass?
==
?
null
?
||
?
!
interfaceClass.isInterface())?
{
????????????
throw
?
new
?IllegalStateException();
????????}
????????Callable
<
T
>
?task?
=
?
new
?CallableImpl();
????????Future
<
T
>
?future?
=
?FutureProxy.service.submit(task);
????????
return
?(T)?Proxy.newProxyInstance(interfaceClass.getClassLoader(),
????????????????
new
?Class
<?>
[]?
{?interfaceClass?}
,?
new
?InvocationHandlerImpl(future));
????}
}
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
