Lines Matching defs:_jobs
53 private BlockingQueue<Runnable> _jobs;
87 _jobs=jobQ;
88 _jobs.clear();
99 if (_jobs==null)
101 _jobs=_maxQueued>0 ?new ArrayBlockingQueue<Runnable>(_maxQueued)
125 _jobs.clear();
128 _jobs.offer(noop);
357 final int jobQ = _jobs.size();
359 if(_jobs.offer(job))
422 return _threadsStarted.get()==_maxThreads && _jobs.size()>=_threadsIdle.get();
520 return _name+"{"+getMinThreads()+"<="+getIdleThreads()+"<="+getThreads()+"/"+getMaxThreads()+","+(_jobs==null?-1:_jobs.size())+"}";
526 return _jobs.poll(_maxIdleTimeMs,TimeUnit.MILLISECONDS);
537 Runnable job=_jobs.poll();
544 job=_jobs.poll();
555 job=_jobs.take();
617 return _jobs;
