线程上下文ThreadContext.docx

import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import org.osgi.framework.Bundle;import org.osgi.framework.BundleEvent;import org.osgi.framework.BundleListener;import com.quickwebframework.entity.Log;import com.quickwebframework.entity.LogFactory;public abstract class ThreadContext private static Log log = LogFactory.getLog(ThreadContext.class); public static void init() final Bundle coreBundle = FrameworkContext.coreBundle; coreBundle.getBundleContext().addBundleListener(new BundleListener() Override public void bundleChanged(BundleEvent arg0) int eventType = arg0.getType(); Bundle bundle = arg0.getBundle(); / 如果插件的状态是正在停止或已经停止 if (eventType = BundleEvent.STOPPED | eventType = BundleEvent.STOPPING) if (bundle.equals(coreBundle) removeAllFilter(); else removeBundleAllThread(bundle); ); private static List threadList = new ArrayList(); private static MapBundle, List bundleThreadListMap = new HashMapBundle, List(); /* * 得到线程列表 * * return */ public static List getThreadList() return threadList; /* * 移除所有的线程 */ public static void removeAllFilter() for (Bundle bundle : bundleThreadListMap.keySet() .toArray(new Bundle0) removeBundleAllThread(bundle); /* * 移除某Bundle所有的线程 * * param bundle */ public static void removeBundleAllThread(Bundle bundle) if (!bundleThreadListMap.containsKey(bundle) return; Thread bundleThreadArray = bundleThreadListMap.get(bundle).toArray( new Thread0); for (Thread thread : bundleThreadArray) removeThread(bundle, thread); bundleThreadListMap.remove(bundle); /* * 移除线程 * * param bundle * param thread */ public static void removeThread(Bundle bundle, Thread thread) / 从Bundle对应的线程列表中移除 if (!bundleThreadListMap.containsKey(bundle) return; List bundleThreadList = bundleThreadListMap.get(bundle); bundleThreadList.remove(thread); / 从所有的线程列表中移除 threadList.remove(thread); String bundleName = bundle.getSymbolicName(); String threadName = String.format( Thread Id:%s ,Name:%s ,Class:%s ,Hashcode:%s, thread.getId(), thread.getName(), thread.getClass().getName(), Integer.toHexString(thread.hashCode(); try errupt(); log.debug(String.format(已成功向插件%s的线程%s发送中断命令！, bundleName, threadName); catch (Exception ex) log.warn(String.format(向插件%s的线程%s发送中断命令失败！, bundleName, threadName); ex.printStackTrace(); /* * 添加线程 * * param bundle * param thread */ public static void addThread(Bundle bundle, Thread thread) String threadClassName = thread.getClass().getName(); / 是否存在同类名实例 boolean hasSameClassNameObject = false; for (Thread preThread : threadList) if (preThread.getClass().getName().equals(threadClassName) hasSameClassNameObject = true; break; / 如果存在同类名实例，则抛出异常 if (hasSameClassNameObject) StringBuilder sb = new StringBuilder(); sb.append(String.format( 警告：将Bundle%s的线程类名:%s加入到ThreadContext中时，发现存在多个同类名实例！, bundle.getSymbolicName(), threadClassName); sb.append(n-同类名实例列表如下：); synchronized (bundleThreadListMap) for (Bundle tmpBundle : bundleThreadListMap.keySet() List tmpBundleThreadList = bundleThreadListMap .get(tmpBundle); for (Thread tmpThread : tmpBundleThreadList) if (tmpThread.getClass().getName() .equals(threadClassName) sb.append(String.format( n -Bundle%s,线程ID:%s ,类名:%s, tmpBundle.getSymbolicName(), tmpThread.getId(), threadClassName); String errorMessage = sb.toString(); log.warn(errorMessage); / 加入到Bundle对应的线程列表中 List bundleThreadList = null; if (bundleThreadListMap.containsKey(bundle) bundleThreadList = bundleThreadListMap.get(bundle); else bundleThreadList = new ArrayList(); bundleThreadListMap.put(bundle, bundleThreadList); bundleThreadList.add(thread); / 加入到全部线程列表中 threadList.add(thread); / 启动线程 t