Resultados da pesquisa a pedido "blockingqueue"
Existe algum contêiner simultâneo em C ++ 11? [fechadas
Em particular, estou procurando uma fila de bloqueio. Existe uma coisa dessas no C ++ 11? Caso contrário, quais são minhas outras opções? Eu realmente não quero mais descer para o nível do tópico. Muito propenso a erros.
C ++ pthread bloqueando o bloqueio da fila (acho)
Estou tendo um problema com pthreads, onde acho que estou tendo um impasse. Eu criei uma fila de bloqueio que eu pensava estar funcionando, mas depois de fazer mais alguns testes, descobri que se eu tentar cancelar vários threads que ...
Como obter o ThreadPoolExecutor para aumentar o máximo de threads antes da fila?
Estou frustrado há algum tempo com o comportamento padrão deThreadPoolExecutor que apóia oExecutorService pools de threads que muitos de nós usamos. Para quo, te dos Javadocs: Se houver mais do que threads corePoolSize, mas menos que ...
Segurança de thread do método drainTo () de BlockingQueue
Documentação de BlockingQueue [http://download.oracle.com/javase/6/docs/api/java/util/concurrent/BlockingQueue.html] diz que operações em massa não são seguras para threads, embora não mencione explicitamente o método drainTo (). s ...
Posso implementar a fila de bloqueio usando o Semaphore em Java?
Gostaria de saber se é possível usar o Semaphore para implementar a fila de bloqueio? Nos códigos abaixo, eu uso um semáforo para proteger a seção crítica e mais dois objetos para rastrear o número de slots vazios e objetos preenchidos. public ...
Equivalente ao canal golang em Java
Eu tenho um requisito no qual preciso ler de um conjunto de filas de bloqueio. As filas de bloqueio são criadas pela biblioteca que estou usando. Meu código precisa ler as filas. Não quero criar um thread de leitor para cada uma dessas filas de ...
Fila de bloqueio e consumidor multiencadeado, como saber quando parar
Tenho um produtor de thread único que cria alguns objetos de tarefa que são adicionados a umArrayBlockingQueue (que é de tamanho fixo). Também inicio um consumidor multiencadeado. Isso é criado como um pool de threads fixo ...
filas de trabalho do produtor / consumidor
Estou lutando com a melhor maneira de implementar meu pipeline de processamento. Meus produtores alimentam o trabalho com um BlockingQueue. No lado do consumidor, pesquiso a fila, envolvo o que recebo em uma tarefa Runnable e a envio a um ...
Existe uma maneira de armazenar uma coleção de “mensagens” de até 1 MB e gravar o resultado no arquivo JSON / CSV
Tenho uma fila de bloqueio que continua recebendo mensagens através de algum aplicativo, agora no aplicativo asp.net tentei consumir a fila e gravar a saída no arquivo CSV / JSO Aqui eu quero armazenar mensagens de até 1 MB que recebam da fila ...
java BlockingQueue não tem uma espiada de bloqueio?
Eu tenho uma fila de bloqueio de objetos.Eu quero escrever um thread que bloqueia até que haja um objeto na fila. Semelhante à funcionalidade fornecida pelo ...
Página 1 do 2