JAVA认证：JAVA线程池的实现及优先级设置

会计考友 · 发表于 2012-8-4 12:44:44

我们巨匠都知道，在措置多线程处事并发时，因为建树线程需要占用良多的系统资本，所觉得了避免这些不需要的损耗，凡是我们采用线程池来解决这些问题。
　　线程池的根基事理是，首先建树并连结必然数目的线程，当需要使用线程时，我们年夜池中取得线程，再将需要运行的使命交给线程进行措置，当使命完成后再将扑晔着回池中。
　　下面，我给出一个很简单的实现模子，仅供参考。
　　ThreadPool.java
　　package org.loon.framework.util.test;
　　import java.util.LinkedList;
　　import java.util.List;
　　/** */ /**
　　*
　　* Title: LoonFramework
　　*
　　*
　　* Description:
　　*
　　*
　　* Copyright: Copyright (c) 2007
　　*
　　*
　　* Company: LoonFramework
　　*
　　*
　　* @author chenpeng
　　* @email：ceponline@yahoo.com.cn
　　* @version 0.1
　　*/
　　public class ThreadPool ... {
　　private static ThreadPool instance = null ;
　　// 优先级低
　　public static final int PRIORITY_LOW = 0 ;
　　// 通俗
　　public static final int PRIORITY_NORMAL = 1 ;
　　// 高
　　public static final int PRIORITY_HIGH = 2 ;
　　// 用以保留余暇毗连
　　private List[] _idxThreads;
　　// 封锁
　　private boolean _shutdown = false ;
　　// 线程数目
　　private int _threadCount = 0 ;
　　// debug信息是否输出
　　private boolean _debug = false ;
　　/** */ /**
　　* 返回ThreadPool实例
　　*
　　* @return
　　*/
　　public static ThreadPool getInstance() ... {
　　if (instance == null ) ... {
　　instance = new ThreadPool();
　　}
　　return instance;
　　}
　　// 初始化线程list
　　private ThreadPool() ... {
　　this ._idxThreads = new List[] ... { new LinkedList(), new LinkedList(),
　　new LinkedList() } ;
　　this ._threadCount = 0 ;
　　}
　　/** */ /**
　　* 同步体例，完成使命后将资本放回线程池中
　　* @param repool

会计考友 · 发表于 2012-8-4 12:44:45

　　*/
　　protected synchronized void repool(Pooled repool) ... {
　　if ( this ._shutdown) ... {
　　if ( this ._debug) ... {
　　System.out.println( " ThreadPool.repool():重设中…… " );
　　}
　　// 优先级别剖断
　　switch (repool.getPriority()) ... {
　　case Thread.MIN_PRIORITY:
　　this ._idxThreads[PRIORITY_LOW].add(repool);
　　break ;
　　case Thread.NORM_PRIORITY:
　　this ._idxThreads[PRIORITY_NORMAL].add(repool);
　　break ;
　　case Thread.MAX_PRIORITY:
　　this ._idxThreads[PRIORITY_HIGH].add(repool);
　　break ;
　　default :
　　throw new IllegalStateException( " 没有此种级别 " );
　　}
　　// 通知所有线程
　　notifyAll();
　　} else ... {
　　if ( this ._debug) ... {
　　System.out.println( " ThreadPool.repool():注销中…… " );
　　}
　　repool.shutDown();
　　}
　　if ( this ._debug) ... {
　　System.out.println( " ThreadPool.repool():完成 " );
　　}
　　}
　　public void setDebug( boolean debug) ... {
　　this ._debug = debug;
　　}
　　public synchronized void shutDown() ... {
　　this ._shutdown = true ;
　　if ( this ._debug) ... {
　　System.out.println( " ThreadPool.shutDown():封锁中…… " );
　　}
　　for ( int index = 0 ;index

会计考友 · 发表于 2012-8-4 12:44:46

　　*/</p>　　public synchronized void start(Runnable target, int priority) ... {
　　Pooled thread = null ;
　　List idleList = this ._idxThreads[priority];
　　int idleSize = idleList.size();
　　if (idleSize > 0 ) ... {
　　int lastIndex = idleSize - 1 ;
　　thread = (Pooled)idleList.get(lastIndex);
　　idleList.remove(idleList);
　　thread.setTarget(target);
　　} else ... {
　　this ._threadCount ++ ;
　　thread = new Pooled(target, " Pooled-> " + this ._threadCount, this );
　　switch (priority) ... {
　　case PRIORITY_LOW:
　　thread.setPriority(Thread.MIN_PRIORITY);
　　break ;
　　case PRIORITY_NORMAL:
　　thread.setPriority(Thread.NORM_PRIORITY);
　　break ;
　　case PRIORITY_HIGH:
　　thread.setPriority(Thread.MAX_PRIORITY);
　　break ;
　　default :
　　thread.setPriority(Thread.NORM_PRIORITY);
　　}
　　// 启动
　　thread.start();
　　}
　　}
　　/** */ /**
　　* 返回线程数目
　　*
　　* @return
　　*/
　　public int getThreadsCount() ... {
　　return this ._threadCount;
　　}
　　}

		自动登录	找回密码
密码			立即注册

[专业语言] JAVA认证：JAVA线程池的实现及优先级设置

JAVA认证：JAVA线程池的实现及优先级设置

JAVA认证：JAVA线程池的实现及优先级设置