示例有关线程池的JAVA

Question

可有人给我，我们已经创建了自己的线程池类来获取线程更好的手感简单的例子。我不想使用java中的Executor Service。我的意思是任何内置类的线程池。

谢谢

Answer 1

这似乎是你在找什么。 http://java.dzone.com/news/java-concurrency-thread-pools

public class ThreadPool { 

    private BlockingQueue taskQueue = null; 
    private List<PoolThread> threads = new ArrayList<PoolThread>(); 
    private boolean isStopped = false; 

    public ThreadPool(int noOfThreads, int maxNoOfTasks){ 
    taskQueue = new BlockingQueue(maxNoOfTasks); 

    for(int i=0; i<noOfThreads; i++){ 
     threads.add(new PoolThread(taskQueue)); 
    } 
    for(PoolThread thread : threads){ 
     thread.start(); 
    } 
    } 

    public void synchronized execute(Runnable task){ 
    if(this.isStopped) throw 
     new IllegalStateException("ThreadPool is stopped"); 

    this.taskQueue.enqueue(task); 
    } 

    public synchronized void stop(){ 
    this.isStopped = true; 
    for(PoolThread thread : threads){ 
     thread.stop(); 
    } 
    } 

} 



public class PoolThread extends Thread { 

    private BlockingQueue taskQueue = null; 
    private boolean  isStopped = false; 

    public PoolThread(BlockingQueue queue){ 
    taskQueue = queue; 
    } 

    public void run(){ 
    while(!isStopped()){ 
     try{ 
     Runnable runnable = (Runnable) taskQueue.dequeue(); 
     runnable.run(); 
     } catch(Exception e){ 
     //log or otherwise report exception, 
     //but keep pool thread alive. 
     } 
    } 
    } 

    public synchronized void stop(){ 
    isStopped = true; 
    this.interrupt(); //break pool thread out of dequeue() call. 
    } 

    public synchronized void isStopped(){ 
    return isStopped; 
    } 
}