ForkJoinPool Classe

Definição

[Android.Runtime.Register("java/util/concurrent/ForkJoinPool", DoNotGenerateAcw=true)]
public class ForkJoinPool : Java.Util.Concurrent.AbstractExecutorService

[<Android.Runtime.Register("java/util/concurrent/ForkJoinPool", DoNotGenerateAcw=true)>]
type ForkJoinPool = class
    inherit AbstractExecutorService

Herança

Object

Object

AbstractExecutorService

ForkJoinPool

Atributos

RegisterAttribute

Comentários

Um ExecutorService para correr ForkJoinTasks. A ForkJoinPool fornece o ponto de entrada para envios de nãoForkJoinTask clientes, bem como operações de gerenciamento e monitoramento.

A ForkJoinPool difere de outros tipos principalmente ExecutorService em virtude de empregar <em>work-stealing</em>: todos os threads no pool tentam encontrar e executar tarefas enviadas ao pool e/ou criadas por outras tarefas ativas (eventualmente bloqueando a espera por trabalho se nenhuma existir). Isso permite um processamento eficiente quando a maioria das tarefas gera outras subtarefas (como a maioria ForkJoinTaskdas s), bem como quando muitas pequenas tarefas são enviadas ao pool de clientes externos. Especialmente ao definir <em>asyncMode</em> como true em construtores, ForkJoinPools também pode ser apropriado para uso com tarefas de estilo de evento que nunca são associadas. Todos os threads de trabalho são inicializados com Thread#isDaemon set true.

Uma estática #commonPool() está disponível e é apropriada para a maioria dos aplicativos. O pool comum é usado por qualquer ForkJoinTask que não é explicitamente enviado para um pool especificado. O uso do pool comum normalmente reduz o uso de recursos (seus threads são recuperados lentamente durante os períodos de não uso e restabelecidos após o uso subsequente).

Para aplicativos que exigem pools separados ou personalizados, um ForkJoinPool pode ser construído com um determinado nível de paralelismo de destino, por padrão, igual ao número de processadores disponíveis. O pool tenta manter threads ativos (ou disponíveis) suficientes adicionando, suspendendo ou retomando dinamicamente threads de trabalho internos, mesmo que algumas tarefas estejam paradas esperando para ingressar em outras. No entanto, esses ajustes não são garantidos em face de E/S bloqueada ou outra sincronização não gerenciada. A interface aninhada ManagedBlocker permite a extensão dos tipos de sincronização acomodados. As políticas padrão podem ser substituídas usando um construtor com parâmetros correspondentes aos documentados na classe ThreadPoolExecutor.

Além dos métodos de execução e controle do ciclo de vida, essa classe fornece métodos de verificação de status (por exemplo #getStealCount) que se destinam a ajudar no desenvolvimento, ajuste e monitoramento de aplicativos de bifurcação/junção. Além disso, o método #toString retorna indicações do estado do pool em uma forma conveniente para monitoramento informal.

Como é o caso de outros ExecutorServices, há três métodos principais de execução de tarefas resumidos na tabela a seguir. Eles são projetados para serem usados principalmente por clientes que ainda não estão envolvidos em cálculos de bifurcação/junção no pool atual. As principais formas desses métodos aceitam instâncias de ForkJoinTask, mas formas sobrecarregadas também permitem a execução mista de atividades simples Runnable- ou Callable- baseadas também. No entanto, as tarefas que já estão sendo executadas em um pool normalmente devem usar os formulários de computação interna listados na tabela, a menos que usem tarefas de estilo de evento assíncronas que geralmente não são associadas, caso em que há pouca diferença entre as opções de métodos.

<table class="plain">caption Resumo dos métodos< de execução de tarefas/caption<>tr<>td></td<>th scope="col"> Chamada de clientes< não-fork/junto/th<>th scope="col"> Chamada de dentro de computação fork/join/<th></tr<>tr<>th scope="row" style="text-align:left"> Organizar execução< assíncrona/th><td>#execute(ForkJoinTask)</td td><ForkJoinTask#fork/td><>><</Tr><tr th scope="row" style="text-align:left"> Aguarde e obtenha result</th<>td#invoke(ForkJoinTask)<>/td><tdForkJoinTask#invoke></td></tr<>tr th<>scope="row" style="text-align:left"> Organize exec e obtenha Future</th<>td#submit(ForkJoinTask)></td<>td>ForkJoinTask#fork (ForkJoinTasks <em>are</em> Futures)</td></tr/table<>><>

Os parâmetros usados para construir o pool comum podem ser controlados definindo as seguintes propriedades do sistema System#getProperty: <ul><lijava.util.concurrent.ForkJoinPool.common.parallelism> - o nível de paralelismo, um inteiro <não negativo li>java.util.concurrent.ForkJoinPool.common.threadFactory - o nome da classe de um .ForkJoinWorkerThreadFactory O carregador de classes do sistema ClassLoader#getSystemClassLoader() é usado para carregar essa classe. <li>java.util.concurrent.ForkJoinPool.common.exceptionHandler - o nome da classe de um UncaughtExceptionHandler. O carregador de classes do sistema ClassLoader#getSystemClassLoader() é usado para carregar essa classe. <li>java.util.concurrent.ForkJoinPool.common.maximumSpares - o número máximo de threads extras permitidos para manter o paralelismo de destino (padrão 256). </ul> Se nenhuma fábrica de threads for fornecida por meio de uma propriedade do sistema, o pool comum usará uma fábrica que usa o carregador de classes do sistema como o carregador de classes de contexto de thread Thread#getContextClassLoader(). Além disso, se um SecurityManager estiver presente, o pool comum usará uma fábrica fornecendo threads que não Permissions têm habilitado.

Em caso de erro no estabelecimento dessas configurações, os parâmetros padrão são usados. É possível desabilitar ou limitar o uso de threads no pool comum definindo a propriedade parallelism como zero e/ou usando uma fábrica que pode retornar null. No entanto, isso pode fazer com que tarefas não unidas nunca sejam executadas.

<b>Notas de implementação:</b> Essa implementação restringe o número máximo de threads em execução a 32767. Tentativas de criar pools com número maior que o máximo resultam em IllegalArgumentException.

Essa implementação rejeita tarefas enviadas (ou seja, lançando RejectedExecutionException) somente quando o pool é desligado ou os recursos internos foram esgotados.

Adicionado em 1.7.

Documentação Java para java.util.concurrent.ForkJoinPool.

Partes desta página são modificações baseadas no trabalho criado e compartilhado pelo Android Open Source Project e usado de acordo com os termos descritos na Creative Commons 2.5 Attribution License.

Construtores

Propriedades

Métodos

Implantações explícitas de interface

Métodos de Extensão

Aplica-se a