Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
COOS - Connected Objects Operating System ( Copyright (C) 2009 Telenor ASA and Tellu AS. All rights reserved. DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. This library is free software: you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this program. If not, see <>. You may also contact one of the following for additional information: Telenor ASA, Snaroyveien 30, N-1331 Fornebu, Norway ( Tellu AS, Hagalokkveien 13, N-1383 Asker, Norway (
package org.coos.messaging.util;

Knut Eilif Husa, Tellu AS Threadpool to use in environments that do not support java.util.concurrent
public class ThreadPool implements ExecutorService {
    private Queue queue = new Queue();
    private int numThreads;
    String name;
    Vector threadPoolThreads = new Vector();
    public ThreadPool(String nameint numThreads) {
        this. = numThreads;
        this. = name;
        // Create N threads
        for (int i = 0; i < numThreads; ++i)
            .addElement(new ThreadPoolThread(this));
    public void execute(Runnable runnable) {
    public void setMaxPoolSize(int maxPoolSize) {
         = maxPoolSize;
        while (.size() < ) {
            .addElement(new ThreadPoolThread(this));
        while (.size() > ) {
            ThreadPoolThread tpt = (ThreadPoolThread.firstElement();
        return (Runnable.get();
    public void stop() {
        for (int i = 0; i < .size(); i++) {
New to GrepCode? Check out our FAQ X