~ubuntu-branches/ubuntu/trusty/ehcache/trusty

/**

 *

 *  Licensed under the Apache License, Version 2.0 (the "License");

 *  you may not use this file except in compliance with the License.

import java.lang.ref.WeakReference;

import java.util.HashSet;

import java.util.Map;

import java.util.Set;

import java.util.WeakHashMap;

import java.util.concurrent.Callable;

import java.util.concurrent.Future;

import java.util.concurrent.FutureTask;

import java.util.concurrent.ThreadFactory;

import java.util.concurrent.atomic.AtomicReference;

 

/**

 * A thread pool that creates another thread pool per requesting thread.

 *

    private final Object workersLock = new Object();

    private final AtomicReference<State> state = new AtomicReference<State>(State.RUNNING);

    private final ReferenceQueue<Thread> gcedThreadsReferenceQueue = new ReferenceQueue<Thread>();

        @Override

        protected WorkerThreadLocal initialValue() {

            synchronized (workersLock) {

    }

 

    /**

     * Private class

     *

     * @author Abhishek Sanoujam

            this.appThreadReference = new WeakWorkerReference(this.worker, Thread.currentThread(), gcedThreadsReferenceQueue);

        }

 

        public void shutdownNow() {

            worker.shutdownNow();

        }

 

        public <T> Future<T> submit(Callable<T> task) {

            worker.addTask(ftask);

            return ftask;

        }

     *

     */

    private static class Worker implements Runnable {

        private final WorkerTaskHolder workerTaskHolder;

        private volatile boolean shutdown;

        private volatile Thread workerThread;

            this.workerTaskHolder = new WorkerTaskHolder();

        }

 

        public void run() {

            workerThread = Thread.currentThread();

            while (!shutdown) {