Resultados da pesquisa a pedido "blockingqueue"
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 ...
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 = ...
Página 2 do 2