*
*/
public class TaskQueue extends LinkedBlockingQueue<Runnable> {
+
+ private static final long serialVersionUID = 1L;
+
private ThreadPoolExecutor parent = null;
public TaskQueue() {
this.threadPriority = priority;
}
+ @Override
public Thread newThread(Runnable r) {
Thread t = new Thread(group, r, namePrefix + threadNumber.getAndIncrement());
t.setDaemon(daemon);
}
}
- private static class RejectHandler implements java.util.concurrent.RejectedExecutionHandler {
- public void rejectedExecution(Runnable r, java.util.concurrent.ThreadPoolExecutor executor) {
+ private static class RejectHandler implements RejectedExecutionHandler {
+ @Override
+ public void rejectedExecution(Runnable r,
+ java.util.concurrent.ThreadPoolExecutor executor) {
throw new RejectedExecutionException();
}