久久精品国产亚洲av高清漫画,伊伊人成亚洲综合人网7777,77777

常用的多線程異步處理

package cn.allinpalm.sns.app.web.point.action;

import java.util.LinkedList;

import org.apache.log4j.Logger;

import cn.allinpalm.sns.app.web.constants.Config;

import cn.allinpalm.sns.app.web.point.service.PointOptService;

import cn.allinpalm.sns.app.web.util.ParamBean;

public class Proccessor {

private static Logger log = Logger.getLogger(Proccessor.class);

class SubProc implements Runnable {

LinkedList<ParamBean> list = new LinkedList<ParamBean>();

void add(ParamBean pb) {

synchronized (list) {

list.add(pb);

list.notify();//通知處理新任務

}

public void run() {

ParamBean pb = null;

while (true) {

try {

synchronized (list) {

if (list.size() > 0) { //存在需要處理的任務

pb = list.remove(0); //將任務移出隊列，并執行業務邏輯

UserOptAction.initPointUserOpt(pb);

if (pb != null && (pb.getOptway()).equals(Config.addPointOpt)) {

PointOptService.userPointAdd(pb);

} else if (pb != null

&& (pb.getOptway())

.equals(Config.consumePointOpt)) {

PointOptService.userPointConsume(pb);

}

} else {

list.wait();//等待任務

}

} catch (InterruptedException e) {

break;

} catch (Exception e) {

break;

}

//單態模式取得實例變量并初始化

private static Proccessor instance = null;

public static Proccessor getInstance() {

if (instance == null) {

instance = new Proccessor();

instance.init();

}

return instance;

}

int max = 20; //創建線程最大數目

SubProc[] procs = null;

//初始化創建20個SubProc對象線程，并啟動

private void init() {

procs = new SubProc[max];

for (int i = 0; i < max; i++) {

procs[i] = new SubProc();

new Thread(procs[i]).start();

}

//ParamBean為業務中參數的封裝Bean，利用hashCode來處理

//將統一用戶的調用放到一個線程統一處理，類似將同一用戶的訪問排隊

public void dispatch(ParamBean pb) {

if (pb != null && procs != null) {

int i = pb.getUserid().hashCode() % max;

if (i < 0) {

i = -i;

}

procs[i].add(pb); //加入線程中處理

}

aciont中調用：

//ation中調用

public ActionForward userPointAddOpt(ActionMapping mapping,

ActionForm form, HttpServletRequest request,

HttpServletResponse response) throws Exception {

ParamBean pb = getParamBeanPk(request, response);

Proccessor.getInstance().dispatch(pb);

}

posted on 2008-03-07 14:13 都市淘沙者閱讀(2603) 評論(0) 編輯收藏所屬分類: Java Basic/Lucene/開源資料

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: BeanComparator實現ArrayList復合排序[轉] 開源中最好的Web開發的資源 java中傳輸對象時候的問題（轉） Java Float類型減法運算時精度丟失問題 ConcurrentHashMap原理分析 http請求的詳細過程【推薦】既有魚肉又有熊掌——ListOrderedMap JAVA異常詳解 javaIO總結 j2ee的性能調優

都市淘沙者

導航

公告

隨筆分類

文章分類

隨筆檔案

文章檔案

相冊

統計

留言簿(23)

積分與排名

優秀學習網站

友情連接

閱讀排行榜

評論排行榜

常用的多線程異步處理