blob: 2bb7d2643a3328a7c731f6f7b23054f62f6be7e6 [file] [log] [blame]
/*******************************************************************************
* Copyright (c) 2007 IBM Corporation and Others
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Hisashi MIYASHITA - initial API and implementation
*******************************************************************************/
package org.eclipse.actf.util.httpproxy.util.impl;
import java.util.ArrayList;
import org.eclipse.actf.util.httpproxy.util.IWorkpileController;
public class WorkpileControllerImpl implements IWorkpileController {
private final String name;
private final ThreadGroup threadGroup;
private final ArrayList workpile;
public void input(Runnable work) {
Thread th;
synchronized (this) {
th = new Thread(threadGroup, work, name + "-" + workpile.size());
workpile.add(th);
}
th.setDaemon(true);
th.start();
}
public String toString() {
return "WPC:[" + name + "]:" + threadGroup.toString();
}
public WorkpileControllerImpl(String name) {
this.name = name;
this.threadGroup = new ThreadGroup(name);
this.workpile = new ArrayList();
}
}