国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁(yè) > 學(xué)院 > 開(kāi)發(fā)設(shè)計(jì) > 正文

Java同步代碼轉(zhuǎn)異步代碼

2019-11-17 04:02:57
字體：大 中 小
來(lái)源：轉(zhuǎn)載
供稿：網(wǎng)友
java同步代碼轉(zhuǎn)異步代碼
Kagula

2009-11-18

摘要
Thread   Thread Group

概要
   利用Java源碼，介紹同步代碼轉(zhuǎn)異步代碼框架的使用，下半部份附框架源代碼，閱讀本文之前可以參考《Java多線(xiàn)程_編程模型研究》http://blog.csdn.net/lee353086/archive/2008/01/10/2033587.aspx



正文
TestThreads.java源碼 用來(lái)示范異步調(diào)用

view plaincopy to clipboardPRint?
import kagula.multithread.MsgManagement;   
  
import org.apache.commons.logging.Log;   
import org.apache.commons.logging.LogFactory;   
  
public class testThreads {   
    private static Log log = LogFactory.getLog(testThreads.class);   
       
    static public void main(String args[])   
    {   
        log.debug("-Test thread.begin!");      
             
        try  
        {   
            Object lockMain=new Object(); //用來(lái)鎖住主線(xiàn)程，可以用來(lái)等待branch thread返回運(yùn)算結(jié)果。   
            MsgManagement mm=new MsgManagement("MsgProc1",lockMain);  //MsgManagement的實(shí)例化   
            String sTN =mm.invoke("t_main",new Class[]  {String.class},new Object[] {new String("FirstT")});   
            String sTN2 =mm.invoke("t_main",new Class[]  {String.class},new Object[] {new String("SecondT")});   
               
            log.debug("sTN="+sTN+" sTN2="+sTN2);               
               
            if(mm.activeCount()>0)  {   
                mm.setMaxPriority(Thread.MAX_PRIORITY);   
               
                synchronized(lockMain)   
                {   
                  lockMain.wait(100);   
                }   
                mm.interrupt();   
            }   
               
            log.debug("mm.getResult(sTN) "+mm.getResult(sTN));   
            log.debug("mm.getResult(sTN2) "+mm.getResult(sTN2));   
        }catch(Exception ex)   
        {   
            ex.printStackTrace();   
        }   
              
        log.debug("-Test thread.end!");   
    }   
}  
import kagula.multithread.MsgManagement;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

public class testThreads {
private static Log log = LogFactory.getLog(testThreads.class);

static public void main(String args[])
{
log.debug("-Test thread.begin!");
  
try
{
Object lockMain=new Object(); //用來(lái)鎖住主線(xiàn)程，可以用來(lái)等待branch thread返回運(yùn)算結(jié)果。
MsgManagement mm=new MsgManagement("MsgProc1",lockMain);  //MsgManagement的實(shí)例化
String sTN =mm.invoke("t_main",new Class[]  {String.class},new Object[] {new String("FirstT")});
String sTN2 =mm.invoke("t_main",new Class[]  {String.class},new Object[] {new String("SecondT")});

log.debug("sTN="+sTN+" sTN2="+sTN2);

if(mm.activeCount()>0)  {
mm.setMaxPriority(Thread.MAX_PRIORITY);

synchronized(lockMain)
{
      lockMain.wait(100);
    }
mm.interrupt();
}

log.debug("mm.getResult(sTN) "+mm.getResult(sTN));
log.debug("mm.getResult(sTN2) "+mm.getResult(sTN2));
}catch(Exception ex)
{
ex.printStackTrace();
}
   
log.debug("-Test thread.end!");
}
}
  



MsgManagement.java  Original Thread.java源碼 ，是異步框架

view plaincopy to clipboardprint?
package kagula.multithread;   
  
import java.util.Collections;   
import java.util.HashMap;   
import java.util.Map;   
  
import org.apache.commons.logging.Log;   
import org.apache.commons.logging.LogFactory;   
  
/**  
* 線(xiàn)程管理器  
*   
* Requirement: JDK1.6.x or above  
*   
* @author Jun Li  
*  
*/  
public class MsgManagement extends ThreadGroup{   
    protected static Log log = LogFactory.getLog(MsgManagement.class);   
       
    private int nID=1;  //auxiliary thread counter flag   
  
    private Map mapResults=Collections.synchronizedMap(new HashMap());  //store threads processing result.   
    private Object lockMain;   
       
//  -----------------below methods using only by main callers.begin-----------------       
    public MsgManagement(String strGroupName,Object pLock)   
    {   
        //Initialization the attributes   
        super(strGroupName);   
        lockMain=pLock;   
    }      
       
    /**  
     * After send processing request,will be return soon.     
     * @param msg  
     * Message  
     * @param nParam  
     * First Parameter  
     * @param secondParam  
     * Second Parameter  
     * @return  
     */  
    public synchronized String invoke(String pMethodName,Class pClass[],Object pObject[]) throws Exception   
    {   
        return invoke(pMethodName,pClass,pObject,lockMain);   
    }   
       
    public synchronized String invoke(String pMethodName,Class pClass[],Object pObject[],Object pLock) throws Exception   
    {   
        String strThreadName=new String("MsgManagement's No."+nID+" thread");   
        MyThread thread=new MyThread(this,strThreadName);   
        thread.setLockMain(pLock);   
        thread.setMethodName(pMethodName);   
        thread.setClassParams(pClass);   
        thread.setObjParams(pObject);   
        thread.start();   
        nID++;   
        return strThreadName;   
    }   
       
    /**  
     * Get result by thread name  
     * @param pThreadName  
     * @return  
     */  
    public Object getResult(String pThreadName)   
    {   
        return mapResults.get(pThreadName);                
    }   
//  -----------------above methods using only by main callers.end-----------------   
       
    //-----------------below methods using only by threads.begin-----------------   
    public void setNResult(String pName,Object pObj)   
    {   
        mapResults.put(pName, pObj);   
    }   
//  -----------------above methods using only by threads.begin-----------------   
}  
package kagula.multithread;

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
* 線(xiàn)程管理器
*
* Requirement: JDK1.6.x or above
*
* @author Jun Li
*
*/
public class MsgManagement extends ThreadGroup{
protected static Log log = LogFactory.getLog(MsgManagement.class);

private int nID=1;  //auxiliary thread counter flag

    private Map mapResults=Collections.synchronizedMap(new HashMap());  //store threads processing result.
    private Object lockMain;
    
//  -----------------below methods using only by main callers.begin-----------------    
    public MsgManagement(String strGroupName,Object pLock)
    {
     //Initialization the attributes
     super(strGroupName);
     lockMain=pLock;
    }

    /**
     * After send processing request,will be return soon.   
     * @param msg
     * Message
     * @param nParam
     * First Parameter
     * @param secondParam
     * Second Parameter
     * @return
     */
public synchronized String invoke(String pMethodName,Class pClass[],Object pObject[]) throws Exception
{
return invoke(pMethodName,pClass,pObject,lockMain);
}

    public synchronized String invoke(String pMethodName,Class pClass[],Object pObject[],Object pLock) throws Exception
    {
String strThreadName=new String("MsgManagement's No."+nID+" thread");
MyThread thread=new MyThread(this,strThreadName);
thread.setLockMain(pLock);
thread.setMethodName(pMethodName);
thread.setClassParams(pClass);
thread.setObjParams(pObject);
thread.start();
nID++;
return strThreadName;
    }
    
    /**
     * Get result by thread name
     * @param pThreadName
     * @return
     */
    public Object getResult(String pThreadName)
    {
     return mapResults.get(pThreadName);         
    }
//  -----------------above methods using only by main callers.end-----------------
    
    //-----------------below methods using only by threads.begin-----------------
public void setNResult(String pName,Object pObj)
{
mapResults.put(pName, pObj);
}
// -----------------above methods using only by threads.begin-----------------
}


view plaincopy to clipboardprint?
package kagula.multithread;   
  
import java.lang.reflect.InvocationTargetException;   
import java.lang.reflect.Method;   
  
import org.apache.commons.logging.Log;   
import org.apache.commons.logging.LogFactory;   
  
/**  
* Your object need derived from it to implement asynchronous method!  
* @author Lijun  
*  
*/  
public abstract class OriginalThread extends Thread{   
    protected static Log log = LogFactory.getLog(OriginalThread.class);     
    protected String MethodName=new String("default");     
    protected Object objParams[];   
    protected Class  classParams[];   
    protected Object lockMain;   
    public OriginalThread(ThreadGroup tg,String name)   
    {   
        super(tg,name);        
    }   
       
    public void run()   
    {   
        log.debug("["+getName()+"] instance of OriginalThread: Before Invoke the method ["+MethodName+"]");   
        Method method=null;   
        Object objR=null;   
        try {   
            method=this.getClass().getMethod(MethodName, classParams);                 
        }catch(NoSuchMethodException e)   
        {   
            log.error(e.toString());   
            return;   
        }   
        if(method!=null)   
        {   
            try {   
                objR=method.invoke(this, objParams);   
            }catch(IllegalaccessException e)   
            {   
                log.error(e.toString());   
                return;   
            }catch(InvocationTargetException e)   
            {   
                log.error(e.toString());   
                return;   
            }catch(IllegalArgumentException e)   
            {   
                log.error(e);   
                return;   
            }   
            catch(Exception e)   
            {   
                log.error(e);   
                return;   
            }   
        }   
        log.debug("["+getName()+"] instance of OriginalThread: After Invoke the method ["+MethodName+"] return value is ["+objR+"]");   
  
        setNResult(objR);  //put setNResult before setNFlag,because assure after nFlag==SUCCESS,caller will get proper result!   
        synchronized(lockMain) {   
            lockMain.notifyAll();   
        }   
    }   
  
    //---------------------below methods only should be used by MsgManagement---------------------   
    private void setNResult(Object pObj)   
    {   
        MsgManagement mm=(MsgManagement)this.getThreadGroup();   
        mm.setNResult(this.getName(), pObj);   
    }      
  
    public void setMethodName(String pMethodName) {   
        this.MethodName = pMethodName;   
    }   
  
    public void setObjParams(Object[] objParams) {   
        this.objParams = objParams;   
    }   
       
    public void setClassParams(Class[] classParams) {   
        this.classParams = classParams;   
    }   
       
    public void setLockMain(Object pLock)   
    {   
        lockMain=pLock;        
    }   
}  
package kagula.multithread;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
* Your object need derived from it to implement asynchronous method!
* @author Lijun
*
*/
public abstract class OriginalThread extends Thread{
protected static Log log = LogFactory.getLog(OriginalThread.class);  
protected String MethodName=new String("default");
protected Object objParams[];
protected Class  classParams[];
protected Object lockMain;
public OriginalThread(ThreadGroup tg,String name)
{
super(tg,name);
}

public void run()
{
log.debug("["+getName()+"] instance of OriginalThread: Before Invoke the method ["+MethodName+"]");
Method method=null;
Object objR=null;
    try {
     method=this.getClass().getMethod(MethodName, classParams);         
    }catch(NoSuchMethodException e)
    {
     log.error(e.toString());
     return;
    }
    if(method!=null)
    {
     try {
     objR=method.invoke(this, objParams);
     }catch(IllegalAccessException e)
     {
     log.error(e.toString());
     return;
     }catch(InvocationTargetException e)
     {
     log.error(e.toString());
     return;
     }catch(IllegalArgumentException e)
     {
     log.error(e);
     return;
     }
     catch(Exception e)
     {
     log.error(e);
     return;
     }
    }
    log.debug("["+getName()+"] instance of OriginalThread: After Invoke the method ["+MethodName+"] return value is ["+objR+"]");

setNResult(objR);  //put setNResult before setNFlag,because assure after nFlag==SUCCESS,caller will get proper result!
synchronized(lockMain) {
lockMain.notifyAll();
}
}

//---------------------below methods only should be used by MsgManagement---------------------
private void setNResult(Object pObj)
{
MsgManagement mm=(MsgManagement)this.getThreadGroup();
mm.setNResult(this.getName(), pObj);
}

public void setMethodName(String pMethodName) {
this.MethodName = pMethodName;
}

public void setObjParams(Object[] objParams) {
this.objParams = objParams;
}

public void setClassParams(Class[] classParams) {
this.classParams = classParams;
}

public void setLockMain(Object pLock)
{
lockMain=pLock;
}
}




MyThread.java是，你同步代碼存放的地方

view plaincopy to clipboardprint?
package kagula.multithread;   
  
import org.apache.commons.logging.LogFactory;   
  
public class MyThread extends OriginalThread{      
    public MyThread(ThreadGroup tg,String name)   
    {   
        super(tg,name);   
           
        log=LogFactory.getLog(this.getClass());   
    }   
       
    public String t_main(String sT)   
    {   
        final long nWaitTime=1*1*5*1000;  //H*M*S,once,more than nWaitTime hours   
           
        String s=null;;   
           
        try{   
            log.debug("before sleep "+sT);                 
            sleep(nWaitTime);   
            log.debug("after sleep "+sT);   
               
            s="I will return. "+sT;   
            return s;   
        }catch(InterruptedException e)   
        {   
            log.error("kagula("+getId()+"):"+e.toString());            
        }   
        return s;   
    }   
}  

發(fā)表評(píng)論 共有條評(píng)論
用戶(hù)名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板： 容城县| 祥云县| 孟津县| 阿鲁科尔沁旗| 诸城市| 象州县| 伊吾县| 瓮安县| 延吉市| 泗洪县| 即墨市| 彭泽县| 铜鼓县| 长丰县| 鹿邑县| 宜丰县| 清原| 荔波县| 启东市| 满洲里市| 吉木萨尔县| 东丽区| 改则县| 布尔津县| 格尔木市| 聊城市| 大荔县| 敦化市| 泰和县| 塔河县| 新河县| 闵行区| 满城县| 太白县| 玉门市| 武胜县| 寻乌县| 昭平县| 柳河县| 米脂县| 水城县|