Resultados da pesquisa a pedido "blockingqueue"
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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.
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 = ...
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 ...
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