Resultados da pesquisa a pedido "nio"
Netty IllegalReferenceCountException
Este é um acompanhamento da minha respostaaqui [https://stackoverflow.com/a/48054615/839733]. Embora minha lógica de negócios não tenha nenhum problema, aconteceu que eu não estava usando o NettyByteBuf. Depois de atualizar meu código de teste ...
Exceção no encadeamento "principal" java.nio.file.InvalidPathException: Char ilegal: <:> no índice 2:
Eu tenho que copiar o recurso classpath de um pacote para outro. Meu programa é: public static void main(String[] args) throws IOException, URISyntaxException { ClassLoader classLoader = ...
Lendo e gravando um arquivo grande usando Java NIO
Como posso ler efetivamente de um arquivo grande e gravar dados em massa em um arquivo usando oJava NIO estrutura. Estou trabalhando comByteBuffer eFileChannel e tinha tentado algo como abaixo: public static void main(String[] args) { String ...
Observando Alterações de Arquivos e Diretórios em Java
Estou escrevendo aqui principalmente para obter conselhos sobre por onde começar. Eu já implementei uma classe que observará recursivamente um diretório usando o WatchService do Java. Ele funciona bem para detectar alterações, mas notei uma falha ...
JIMFS não reconhecido pelo ZipFileSystemProvider
Eu tenho um arquivo zip criado emjimfs [https://github.com/google/jimfs](google no sistema de arquivos de memória) de uma matriz de bytes. Ao tentar abrir esse arquivo comZipMemoryFileSystem, Recebo um erro que o provedor não é reconhecido. Meu ...
Java - Quando o buffer direto é lançado?
Como está fora do jvm heap & gc, quando é lançado? Ou permanece até o término do processo? Eu já verifiquei: como lixo coletar um java de buffer ...
Java.nio: exclusão recursiva de diretório mais concisa
No momento, estou tentando excluir recursivamente um diretório ... Estranhamente, o menor pedaço de código que consegui encontrar é a seguinte construção, empregando umclasse interna ad-hoc e em umpadrão de visitante... Path rootPath = ...
kafka.consumer.SimpleConsumer: reconexão devido a erro de soquete: java.nio.channels.ClosedChannelException
Estou executando um consumidor simples para kafka como este: int timeout = 80000; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);Isso funciona bem por algumas horas, mas recebo uma exceção ...
Por que File.exists () está se comportando de maneira inadequada em um ambiente multithread?
Eu tenho um processo em lote em execução no java JDK 1.7. Está sendo executado em um sistema com RHEL, 2.6.18-308.el5 # 1 SMP. Esse processo obtém uma lista de objetos de metadados de um banco de dados. A partir desses metadados, ele extrai um ...
Por que o fluxo paralelo Files.list () está executando muito mais lentamente do que usando Collection.parallelStream ()?
O fragmento de código a seguir faz parte de um método que obtém uma listagem de diretório, chama um método de extração em cada arquivo e serializa o objeto de droga resultante para xml. try(Stream<Path> paths = Files.list(infoDir)) { paths ...