- ¿Cuáles son las prioridades del hilo?
La respuesta a esta pregunta está en las conferencias de JavaRush.
Para optimizar el funcionamiento paralelo de subprocesos en Java, es posible establecer prioridades de subprocesos. Los subprocesos con mayor prioridad tienen la ventaja de recibir tiempo de CPU sobre los subprocesos con menor prioridad.
El trabajo con prioridades lo proporcionan los siguientes métodos de clase
Thread
:public final void setPriority(int newPriority)
Establece la prioridad del hilo.
public final int getPriority()
Le permite conocer la prioridad del hilo.
El valor de un parámetro en un método
setPriority
no puede ser arbitrario. Debe estar entre MIN_PRIORITY y MAX_PRIORITY. Cuando se crea, un hilo tiene prioridad NORM_PRIORITY.PRIORIDAD_MINA = 1.
PRIORIDAD_NORM =5.
MAX_PRIORIDAD = 10. -
¿Es posible detener un hilo reduciendo su prioridad a 0?
La respuesta está en el artículo: “Las 50 preguntas principales de la entrevista. Tema: subprocesos múltiples"
Lo encontré en el foro.
Hay una versión en inglés de este artículo: Las 50 preguntas principales de la entrevista sobre temas de Java, respuestas para programadores novatos y experimentados
Java proporciona API enriquecidas para todo, pero, irónicamente, no proporciona ninguna forma conveniente de detener un hilo. Si bien JDK 1.0 tenía varios métodos de control, como
stop()
,suspend()
yresume()
, que se marcaron como obsoletos en versiones futuras debido a posibles amenazas de interbloqueo, los desarrolladores de la API de Java no han hecho ningún intento desde entonces de proporcionar una manera robusta, segura para subprocesos y elegante de detener hilos. Los programadores confían principalmente en el hecho de que el hilo se detiene tan pronto como termina de ejecutar métodosrun()
ocall()
. Para detener manualmente, los programadores aprovechanvolatile boolean
la variable y verifican su valor en cada iteración si el métodorun()
tiene bucles, o interrumpen subprocesos con el métodointerrupt()
para cancelar trabajos abruptamente.Específicamente sobre la pregunta: nunca he visto a nadie establecer la prioridad en 0.
Si alguien sabe algo sobre esto que escriba en los comentarios.
-
¿ Por qué necesitamos una clase
ThreadGroup
?ThreadGroup
es un conjunto de subprocesos que también puede contener otros grupos de subprocesos. Un grupo de subprocesos forma un árbol en el que todos los demás grupos de subprocesos tienen un padre (excepto el original). Un hilo tiene derecho a acceder a los datos de su grupo de hilos, pero no tiene ese acceso a otros grupos ni a su grupo de hilos principal. -
¿ A qué grupo de hilos pertenece
main-thread
?No lo encontré por ningún lado)) Dime dónde está))
-
¿ Qué es un patrón
ThreadPool
?Hay un extracto sobre esto del artículo de Wikipedia:
In computer programming, the thread pool pattern (also replicated workers or worker-crew model) is where a number of threads are created to perform a number of tasks, which are usually organized in a queue. The results from the tasks being executed might also be placed in a queue, or the tasks might return no result (for example, if the task is for animation). Typically, there are many more tasks than threads. As soon as a thread completes its task, it will request the next task from the queue until all tasks have been completed. The thread can then terminate, or sleep until there are new tasks available.
The number of threads used is a parameter that can be tuned to provide the best performance. Additionally, the number of threads can be dynamic based on the number of waiting tasks. For example, a web server can add threads if numerous web page requests come in and can remove threads when those requests taper down. The cost of having a larger thread pool is increased resource usage. The algorithm used to determine when to create or destroy threads will have an impact on the overall performance:
- create too many threads, and resources are wasted and time also wasted creating any unused threads
- destroy too many threads and more time will be spent later creating them again
- creating threads too slowly might result in poor client performance (long wait times)
В компьютерном программировании есть модель пула потоков, где определенное число потоков создается для выполнения целого ряда задач, которые обычно организуются в очереди. Результаты от выполненных задач также могут быть помещены в очередь, либо задачи могут не возвращать ниCómoого результата (например, если задача для анимации).
Как правило, существует гораздо больше задач, чем потоков. Как только поток завершит свою задачу, он будет запрашивать следующую задачу из очереди, пока все задачи не будут завершены. Поток может затем прерваться o заснуть. Количество используемых потоков, это параметр, который может быть настроен, для обеспечения наилучшей производительности. Кроме того, число потоков может быть динамическим на основе количества возникающих задач. Например, веб-servidor может добавлять потоки, если pedidoы многочисленных веб-страниц приходят и может удалить потоки, когда этих pedidoов становится меньше. С увеличением размера пула потоков увеличивается использование ресурсов компьютера. Алгоритм, используемый для определения того, когда создавать o уничтожать потоки, будет иметь влияние на общую производительность: - Создать слишком много потоков значит тратить ресурсы и время впустую.
Уничтожить слишком много потоков и больше времени будет потрачено позже снова для их создания - Creación потоков слишком медленно, может привести к снижению производительности клиента.
-
Зачем нужен класс
ThreadPoolExecutor
?public class ThreadPoolExecutor extends AbstractExecutorService
ExecutorService
это выполняет каждую представленную задачу, используя один возможно из нескольких объединенных в пул потоков, обычно сконфигурированное использованиеExecutors
методы фабрики.Пулы потоков рассматривают две различных проблемы: они обычно обеспечивают улучшенную производительность, выполняя большие количества асинхронных задач, из-за уменьшенных издержек вызова на задачу, и они обеспечивают средство ограничения и управления ресурсами, включая потоки, использованные, выполняя набор задач. Каждый
ThreadPoolExecutor
также поддерживает немного основной статистики, такой Cómo число завершенных задач.Quéбы быть полезным через широкий диапазон контекстов, этот класс обеспечивает много корректируемых параметров и рычагов расширяемости. Однако, программистов убеждают использовать более удобное
Executors
методы фабрикиExecutors.newCachedThreadPool()
(неограниченный пул потоков, с автоматическим восстановлением потока),Executors.newFixedThreadPool(int)
(пул потоков фиксированного размера) иExecutors.newSingleThreadExecutor()
(единственный фоновый поток), которые предварительно конфигурируют настройки для наиболее распространенных сценариев использования. -
Сколько способов создать нить вы знаете?
На уровне языка есть два способа создания нити. Объект класса
java.lang.Thread
представляет собой нить, но ей требуется задача для исполнения, которая является un objetoом, реализующим интерфейсjava.lang.Runnable
. Так Cómo классThread
реализует интерфейсRunnable
, вы можете переопределить методrun()
унаследовав ваш класс отThread
o реализовав в нём интерфейсRunnable
. -
Для чего используется класс
Future
?Future
хранит результат асинхронного вычисления. Вы можете запустить вычисление, предоставив кому-либо un objetoFuture
, и забыть о нем. Владелец un objetoаFuture
может получить результат, когда он будет готов. -
В чем преимущества
Callable
надRunnable
?Ссылка: Часть 2. Выполнение задач в многопоточном режиме
Интерфейс
Callable
гораздо больше подходит для создания задач, предназначенных для параллельного выполнения, нежели интерфейсRunnable
o тем более классThread
. При этом стоит отметить, что возможность добавить подобный интерфейс появилась только начиная с версии Java 5, так Cómo ключевая особенность интерфейсаCallable
– это использование параметризованных типов (generics), Cómo показано в листинге.Листинг Creación задачи с помощью интерфейса Callable 10 1 import java.util.concurrent.Callable; 11 2 public class CallableSample implements Callable
{ 12 3 public String call() throws Exception { 13 4 if(Cómoое-то condición) { 14 5 throw new IOException("error during task processing"); 15 6 } 16 7 System.out.println("task is processing"); 17 8 return "result "; 18 9 } 19 10 } Сразу необходимо обратить внимание на строку 2, где указано, что интерфейс
Callable
является параметризованным, и его конкретная реализация – классCallableSample
, зависит от типаString
. На строке 3 приведена сигнатура основного методаcall
в уже параметризованном варианте, так Cómo в качестве типа возвращаемого значения также указан типString
. Фактически это означает, что была создана задача, результатом выполнения которой будет un objeto типаString
(см. строку 8). Точно также можно создать задачу, в результате работы которой в методеcall
будет создаваться и возвращаться un objeto любого требуемого типа. Такое решение значительно удобнее по сравнению с методом run в интерфейсеRunnable
, который не возвращает ничего (его возвращаемый тип –void
) и поэтому приходится изобретать обходные пути, чтобы извлечь результат работы задачи.Еще одно преимущество интерфейса
Callable
– это возможность «выбрасывать» исключительные ситуации, не оказывая влияния на другие выполняющиеся задачи. На строке 3 указано, что из метода может быть «выброшена» исключительная ситуация типаException
, что фактически означает любую исключительную ситуацию, так Cómo все исключения являются потомкамиjava.lang.Exception
. На строке 5 эта возможность используется для создания контролируемой (checked) исключительной ситуации типаIOException
. Методrun
интерфейсаRunnable
вообще не допускал выбрасывания контролируемых исключительных ситуаций, а выброс неконтролируемой (runtime) исключительной ситуации приводил к остановке потока и всего aplicaciones. -
Можно ли отменить выполнение задачи, если использовать класс
Future
?Исходя из этой дискуссии, поднятой на хабре, выходит, что нельзя.
У
Future
есть методFuture.cancel(boolean)
, который должен отменить выполнение задачи. Но если задача уже начала выполняться, вызовFuture.cancel(true)
на самом деле не остановит ее. В недрах реализацииFutureTask
выполняется código:if (mayInterruptIfRunning) { Thread r = runner; if (r != null) r.interrupt(); }
Т.е. опять потоку, в котором выполняется задача, всего лишь рекомендуется прекратить выполнение. К тому же, мы не имеем даже возможности узнать выполняется ли задача в данный момент o нет. Есть, метод
Future.isDone()
, но опять мимо, он возвращает true не только когда задача завершила выполнение, а сразу после вызоваFuture.cancel()
, даже если задача все еще выполняется (ведьFuture.cancel(true)
не останавливает задачу которая уже начала выполняться).Хорошо, если мы сами пишем весь código, тогда можно в нужных местах аккуратно обрабатывать
Thread.isInterrupted()
и все будет ОК. Но если мы запускаем сторонний código? Если у нас есть servidor расширяемый с помощью плагинов? Какой-нибудь криво написанный плагин может pedidoто привести к неработоспособному состоянию весь servidor ведь мы не можем корректно прервать выполнение зависшего enchufar.
DefNeo
Nivel 36
GO TO FULL VERSION