2011年9月2日		  

          


		
          
			
          ibatis分頁<一>
          
			
			
          package com.lxy.dialect;
          public abstract interface Dialect {
          	
          	public boolean supportLimit();
          	
          	public String getLimitString(String sql,boolean hasoffset);
          	
          	public String getLimitString(String sql,int offset,int limit);
          }


          package com.lxy.dialect;
          public class MyDialect implements Dialect {
          	protected static final String SQL_END_DELIMITER = ";";
          	public String getLimitString(String sql, boolean hasoffset) {
          		return new StringBuffer(sql.length() + 20).append(trim(sql)).append(
          				hasoffset ? "limit ?,?" : "limit ?").append(SQL_END_DELIMITER)
          				.toString();
          	}
          	public String getLimitString(String sql, int offset, int limit) {
          		sql = trim(sql);
          		StringBuffer sb = new StringBuffer(sql.length() + 20);
          		sb.append(sql);
          		if (offset > 0) {
          			sb.append("limit").append(offset).append(',').append(limit).append(
          					";");
          		} else {
          			sb.append("limit").append(limit).append(";");
          		}
          		return sb.toString();
          	}
          	public boolean supportLimit() {
          		return true;
          	}
          	private String trim(String sql) {
          		sql = sql.trim();
          		if (sql.endsWith(";")) {
          			sql = sql.substring(0, sql.length() - 1 - ";".length());
          		}
          		return sql;
          	}
          }
          
			
			
          		
				posted @ 2011-09-14 19:11 crazy-李陽 閱讀(212) | 評論 (0) | 編輯 收藏
			
          
		
          
	
		
          
			
          線程池代碼
          
			
			
          ThreadPoolManager

          package com.threadpool.test;
          import java.util.LinkedList;
          import java.util.Queue;
          import java.util.concurrent.ArrayBlockingQueue;
          import java.util.concurrent.Executors;
          import java.util.concurrent.RejectedExecutionException;
          import java.util.concurrent.RejectedExecutionHandler;
          import java.util.concurrent.ScheduledExecutorService;
          import java.util.concurrent.ScheduledFuture;
          import java.util.concurrent.ThreadPoolExecutor;
          import java.util.concurrent.TimeUnit;

          import org.omg.CORBA.TIMEOUT;

          import com.nio.test.ReadFileThread;

          public class ThreadPoolManager {

              private static ThreadPoolManager tpm = new ThreadPoolManager();

              // 線程池最小線程數
              private final static int MIN_SIZE = 4;
              // 線程池最大線程數
              private final static int MAX_SIZE = 10;
              // 線程池維護線程允許的空閑限制
              private final static int KEEP_ACTIVE_TIME = 0;
              // 線程池用的緩沖隊列大小
              private final static int WORK_QUEUE_SIZE = 10;
              // 消息緩沖隊列
              Queue queue = new LinkedList();
              
              final Runnable accessBuffeThread = new Runnable()
              {

                  public void run() {
                      
                      if( hasMoreAcquire() ){
                          
                          String msg = ( String ) queue.poll();
                          Runnable task = new AccessDBThread( msg );
                          threadpool.execute( task );
                      }
                  }
                  
              };
              // 無法由 ThreadPoolExecutor 執行的任務的處理程序
              final RejectedExecutionHandler handler = new RejectedExecutionHandler()
              {

                  public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                      // TODO Auto-generated method stub
                      System.out.println(((AccessDBThread )r).getMsg()+"消息放入隊列中重新等待執行");
                      queue.offer((( AccessDBThread ) r ).getMsg() );
                  }
                  
              };
              
              final ThreadPoolExecutor threadpool = new ThreadPoolExecutor(MIN_SIZE, MAX_SIZE, KEEP_ACTIVE_TIME, TimeUnit.SECONDS, new ArrayBlockingQueue(WORK_QUEUE_SIZE),this.handler);
              
              // 調度線程池

              final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool( 1 );

              final ScheduledFuture taskHandler = scheduler.scheduleAtFixedRate(accessBuffeThread, 0, 1, TimeUnit.SECONDS);
              
              public static ThreadPoolManager newinstance()
              {
                  return tpm;
              }
              
              private ThreadPoolManager (){}
              
              
              private boolean hasMoreAcquire()
              {
                  return !queue.isEmpty();
              }
              
              public void addLogMsg(String msg)
              {
               Runnable task = new AccessDBThread(msg);
               threadpool.execute(task);
              }
          }
          AccessDBThread
          package com.threadpool.test;

          public class AccessDBThread implements Runnable{

              private String msg;
              public String getMsg() {
                  return msg;
              }
              public void setMsg(String msg) {
                  this.msg = msg;
              }
              
              public AccessDBThread(){
                  super();
              }
              
              public AccessDBThread(String msg)
              {
                  this.msg=msg;
              }
              public void run() {
                  // TODO Auto-generated method stub
                  System.out.println("Added the message: "+msg+" into the Database");
              }

              
          }

          測試類：
          package com.threadpool.test;


          public class TestDriver {

              ThreadPoolManager tpm = ThreadPoolManager.newinstance();
              
              public void addMsg(String msg)
              {
                  tpm.addLogMsg(msg);
              }
              public static void main(String[] args) {
                  for(int i=0;i<100;i++)
                  {
                      new TestDriver().addMsg(Integer.toString(i));
                  }
              }
          }



          
			
			
          		
				posted @ 2011-09-02 15:20 crazy-李陽 閱讀(418) | 評論 (0) | 編輯 收藏
			
          
		
          
	


				
				

			
          
			
          
				
					
          
	
          
		
          <2011年9月>
          
	
          日一二三四五六
          28293031123
          45678910
          11121314151617
          18192021222324
          2526272829301
          2345678
          

          

					

          導航
          

					

          統計
          
	
					
					

          常用鏈接
          


          留言簿
          


		
          隨筆檔案
          
		
				
			
	



          搜索
          



          最新評論
	
          

          
	

          


          閱讀排行榜
          



          評論排行榜
          


				
			
          
			
			
			
			
			 

	

    
          
        
	




主站蜘蛛池模板：
桃源县|
遂溪县|
瑞昌市|
商都县|
大余县|
宁武县|
开封市|
锡林浩特市|
白河县|
柏乡县|
神木县|
萨迦县|
依兰县|
丽水市|
平湖市|
上饶县|
宁乡县|
玉山县|
克东县|
马公市|
忻州市|
额济纳旗|
叙永县|
东台市|
木里|
渑池县|
分宜县|
漾濞|
建宁县|
阿合奇县|
广昌县|
凯里市|
鄂托克前旗|
贵阳市|
南和县|
惠东县|
蒙山县|
林周县|
岗巴县|
长阳|
靖边县|