Mercurial Hosting > luan

comparison src/org/eclipse/jetty/util/thread/QueuedThreadPool.java @ 820:8e9db0bbf4f9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove org.eclipse.jetty.util.log and upgrade slf4j
author Franklin Schmidt <fschmidt@gmail.com>
date Tue, 13 Sep 2016 23:13:06 -0600
parents 3428c60d7cfc
children 88d3c8ff242a
comparison
equal deleted inserted replaced
819:17bd0b170ed6 820:8e9db0bbf4f9
35 import org.eclipse.jetty.util.BlockingArrayQueue; 35 import org.eclipse.jetty.util.BlockingArrayQueue;
36 import org.eclipse.jetty.util.component.AbstractLifeCycle; 36 import org.eclipse.jetty.util.component.AbstractLifeCycle;
37 import org.eclipse.jetty.util.component.AggregateLifeCycle; 37 import org.eclipse.jetty.util.component.AggregateLifeCycle;
38 import org.eclipse.jetty.util.component.Dumpable; 38 import org.eclipse.jetty.util.component.Dumpable;
39 import org.eclipse.jetty.util.component.LifeCycle; 39 import org.eclipse.jetty.util.component.LifeCycle;
40 import org.eclipse.jetty.util.log.Log; 40 import org.slf4j.Logger;
41 import org.eclipse.jetty.util.log.Logger; 41 import org.slf4j.LoggerFactory;
42 import org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool; 42 import org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool;
43 43
44 public class QueuedThreadPool extends AbstractLifeCycle implements SizedThreadPool, Executor, Dumpable 44 public class QueuedThreadPool extends AbstractLifeCycle implements SizedThreadPool, Executor, Dumpable
45 { 45 {
46 private static final Logger LOG = Log.getLogger(QueuedThreadPool.class); 46 private static final Logger LOG = LoggerFactory.getLogger(QueuedThreadPool.class);
47 47
48 private final AtomicInteger _threadsStarted = new AtomicInteger(); 48 private final AtomicInteger _threadsStarted = new AtomicInteger();
49 private final AtomicInteger _threadsIdle = new AtomicInteger(); 49 private final AtomicInteger _threadsIdle = new AtomicInteger();
50 private final AtomicLong _lastShrink = new AtomicLong(); 50 private final AtomicLong _lastShrink = new AtomicLong();
51 private final ConcurrentLinkedQueue<Thread> _threads=new ConcurrentLinkedQueue<Thread>(); 51 private final ConcurrentLinkedQueue<Thread> _threads=new ConcurrentLinkedQueue<Thread>();
579 } 579 }
580 } 580 }
581 } 581 }
582 catch(InterruptedException e) 582 catch(InterruptedException e)
583 { 583 {
584 LOG.ignore(e); 584 LOG.trace("",e);
585 } 585 }
586 catch(Exception e) 586 catch(Exception e)
587 { 587 {
588 LOG.warn(e); 588 LOG.warn("",e);
589 } 589 }
590 finally 590 finally
591 { 591 {
592 if (!shrink) 592 if (!shrink)
593 _threadsStarted.decrementAndGet(); 593 _threadsStarted.decrementAndGet();