Resultados da pesquisa a pedido "blockingqueue"
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 ...
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 ...
Queue completo, profundidade da fila de bloqueio, esclarecimentos necessários
Ao preencher a fila a partir do conteúdo do arquivo, a profundidade parece nunca aumentar, pois os elementos não são adicionados nesta implementaçã BlockingQueue<String> q = new SynchronousQueue<String>(); ... fstream = ...
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 ...
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.
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 ...
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 ...
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 ...
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 ...
O que há de errado com a minha técnica de monitoramento de sensores?
(Por favor, leia UPDATE 3 no final) Estou desenvolvendo um aplicativo que funciona continuamente com os sensores do dispositivo, trabalha com
Página 1 do 2