ThreadPoolExecutor - ArrayBlockingQueue ... ждать, прежде чем она удаляет элемент формирования очереди

Question

Я пытаюсь Tune нить, которая делает следующее:

Нить бассейн только с 1 нить [CorePoolSize =0, maxPoolSize = 1]

Очередь используется является ArrayBlockingQueue

Quesize = 20

BackGround:
Поток пытается прочитать запрос и выполнить операцию над ним.

ОДНАКО, в конечном итоге запросы увеличились настолько, что поток всегда занят и потребляет 1 процессор, что делает его ресурсоемкой.

Что я хочу сделать, вместо этого выборочно проверяйте запросы и обрабатывайте их. Другие запросы можно безопасно игнорировать.

Что мне нужно сделать, так это спящий режим «операция», так что для каждой задачи поток спит когда-то и освобождает процессор.

Quesiton:
Однако, мне было интересно, если есть способ использовать очереди, которая в основном сам спит на некоторое время, прежде чем он читает следующий элемент. Это было бы идеально, так как спящая задача в середине исполнения, и выполнение неполного исполнения просто не кажется мне лучшим.

Пожалуйста, дайте мне знать, если у вас есть какие-либо другие предложения, а также для выполнения задач

Спасибо.

Edit: Я добавил последующий вопрос here исправлен размер maxpool быть 1 [написано в спешке] .. спасибо тим за указание его.

Answer 1

Нет, вы не можете заставить поток спать, пока он находится в бассейне. Если в очереди есть задача, она будет выполнена.

Приостановка в задаче с очередью - единственный способ заставить поток простаивать, несмотря на поставленные в очередь задачи. Теперь «спящий» не должен находиться в той же задаче, что и «работа» —, после каждой реальной задачи вы можете поставить отдельную задачу отдыха, что может привести к более чистой реализации. Что еще более важно, если работа - это Callable, которая возвращает результат, разделение на две задачи позволит вам получить результат как можно скорее.

В качестве уточнения, вместо того, чтобы спать в течение фиксированного интервала между каждой задачей, вы можете «дросселировать» выполнение до указанной скорости. Это позволит вам избежать ненужного ожидания между задачами, но не запускать слишком много задач в течение заданного интервала времени. Вы можете read another answer of mine для простого способа реализовать это с помощью DelayQueue.

Answer 2

Вы можете подкласс и переопределить ThreadPool beforeExecute спать в течение некоторого времени:

@Overrides 
protected void beforeExecute(Thread t, 
         Runnable r){ 
    try{ 
     Thread.sleep(millis); // will sleep the correct thread, see JavaDoc 
    } 
    catch (InterruptedException e){} 

    } 

Но увидеть комментарий AngerClown в об искусственно замедляя очередь, вероятно, не является хорошей идеей.

Answer 3

Это может не сработать для вас, но вы можете попробовать установить приоритет потока исполнителей на низкий.

По существу, создайте ThreadPoolExecutor с обычным ThreadFactory. Попросите метод ThreadFactory.newThread() Threads с приоритетом Thread.MIN_PRIORITY. Это приведет к тому, что сервис-исполнитель, который вы используете, должен быть запланирован только в том случае, если имеется доступное ядро ​​для его запуска.

Импликация: в системе, которая строго использует временную привязку, вам будет предоставлен только временной срез, если нет другого потока во всей программе с большим приоритетом, требующим назначения. В зависимости от того, насколько занято ваше приложение на самом деле, вы можете получать расписание каждый раз через некоторое время, иначе вы не можете планировать вообще.

Answer 4

Причина, по которой поток потребляет 100% процессор, потому что ему дается больше работы, чем он может обрабатывать. Добавление задержки между задачами не решит эту проблему. Это только ухудшает ситуацию.

Вместо этого вы должны посмотреть, ПОЧЕМУ ваши задачи потребляют столько CPU, например. с профайлером и смените их так, чтобы потреблять меньше CPU, пока не обнаружите, что ваш поток может не отставать, и он больше не потребляет 100% -ный процессор.