akka limitação das threads

[Rodrigo]

Pessoal,

Estou precisando limitar a qualidade de threads que o akka deve abrir.

Alguém sabe qual configuração devo mexer?

Obrigado,

Abss

[Aristofanio Garcia de Araújo]

Olá!

Veja a página http://doc.akka.io/docs/akka/snapshot/general/configuration.html, lá você pode configurar o pool de threads.

Procure por "max-pool-size-max" no arquivo de configuração.

Espero ter ajudado.

Ari

> Date: Wed, 6 Jun 2012 17:28:00 -0700
> From: dgro...@gmail.com
> To: scal...@googlegroups.com
> Subject: [scala-br] akka limitação das threads

[Rodrigo Almeida]

Aristofanio,

Eu já configurei esse cara no meu dispatcher mas mesmo assim ele continua abrindo um monte de thread.

abs,

Rodrigo

[Aristofanio Garcia de Araújo]

Voce pode mandar o seu código de teste para eu poder avaliar, pois aqui fiz o teste e funciona... 

Manda teu "código de teste" para podermos avaliar melhor.

Ari

---

Date: Wed, 6 Jun 2012 22:48:06 -0300
Subject: Re: [scala-br] akka limitação das threads
From: dgro...@gmail.com
To: scal...@googlegroups.com

[Rodrigo Almeida]

Puts eu tenho ele lá na empresa.

Você utilizou o dispatcher ? ou alterou de outra forma ?

abs,

Rodrigo

[Aristofanio Garcia de Araújo]

Eu usei outra estratégia, mas acredito seja apenas uma questão de detalhe... Vou criar um test com dispatcher... 

Ari

---

Date: Wed, 6 Jun 2012 23:47:26 -0300

[Rodrigo Almeida]

Cara tem como vc me mandar como você fez ? 

obrigado pela ajuda.

abs,

Rodrigo

[Rodrigo Almeida]

Cara, 

Segue o meu arquivo de dispatcher application.conf como você pode ver passei ele todo para 1 e mesmo assim ele abre 1000 threads.

pacotes-dispatcher {

  # Dispatcher is the name of the event-based dispatcher

  type = Dispatcher

  # What kind of ExecutionService to use

  executor = "thread-pool-executor"

  

  # This will be used if you have set "executor = "fork-join-executor""

  fork-join-executor {

# Min number of threads to cap factor-based parallelism number to

parallelism-min = 1

# Parallelism (threads) ... ceil(available processors * factor)

parallelism-factor = 1.0

# Max number of threads to cap factor-based parallelism number to

parallelism-max = 1

  }

  

  # Configuration for the thread pool

  thread-pool-executor {

    # minimum number of threads to cap factor-based core number to

    core-pool-size-min = 1

    # No of core threads ... ceil(available processors * factor)

    core-pool-size-factor = 1.0

    # maximum number of threads to cap factor-based number to

    core-pool-size-max = 1

# Hint: max-pool-size is only used for bounded task queues

# minimum number of threads to cap factor-based max number to

max-pool-size-min = 1

 

# Max no of threads ... ceil(available processors * factor)

max-pool-size-factor  = 1.0

 

# Max number of threads to cap factor-based max number to

max-pool-size-max = 1

# Specifies which type of task queue will be used, can be "array" or

# "linked" (default)

task-queue-type = "linked"

# Specifies the bounded capacity of the task queue (< 1 == unbounded)

task-queue-size = 1

  }

  

  mailbox-capacity = 1

  

  # Throughput defines the maximum number of messages to be

  # processed per actor before the thread jumps to the next actor.

  # Set to 1 for as fair as possible.

  throughput = 1

}

abs,

Rodrigo

[Aristofanio Garcia de Araújo]

Segue meu código de teste em anexo. 

Neste código você pode mudar a configuração do application.conf que funciona. 

Como eu disse antes, não utilizei o Dispatcher, mas o principio é o mesmo. Vou tentar fazer isto a noite, para tentar reprodiz seu problema

Ari

---

Date: Thu, 7 Jun 2012 10:14:41 -0300

[Aristofanio Garcia de Araújo]

Segue um teste que fiz utilizando Dispatcher.

Dentro do arquivo em anexo tem uma pasta chamada img que possui umas imagens que estou usando para evidenciar o controle do número de threads.

Espero ter ajudado!

Ari 

---

From: arist...@hotmail.com
To: scal...@googlegroups.com
Subject: RE: [scala-br] akka limitação das threads
Date: Thu, 7 Jun 2012 12:11:58 -0300