Resultados da pesquisa a pedido "nio"
quando eu uso o nio, serverSocket.accept () lança IllegalBlockingModeException
Quando eu codigo assim: ServerSocketChannel ssc = ServerSocketChannel.open(); InetSocketAddress sa = new InetSocketAddress("localhost",8888); ssc.socket().bind(sa); ssc.configureBlocking(false); ...
Lendo um arquivo GZIP de um FileChannel (Java NIO)
Eu preciso ler / descompactar um arquivo .gz, dado um FileChannel. Eu brinquei com a extração de arquivos GZIP usando GZIPInputStream, mas isso não requer um FileChannel. Não tenho acesso ao FileInputStream original do qual o FileChannel foi ...
Cópia em duplicado () da ByteBuffer do Java
java.nio.ByteBuffer#duplicate() retorna um novo buffer de bytes que compartilha o conteúdo do buffer antigo. Alterações no conteúdo do buffer antigo serão visíveis no novo buffer e vice-versa. E se eu quiser uma cópia profunda do buffer de bytes?
Files.newDirectoryStream vs. Files.list
Estou ciente de queFiles.list (Caminho) [http://docs.oracle.com/javase/8/docs/api/java/nio/file/Files.html#list-java.nio.file.Path-] usaFiles.newDirectoryStream ...
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 ...
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 ...
Desalocando a Memória Nativa do Buffer Direto em Java para JOGL
Estou usando buffers diretos (java.nio) para armazenar informações de vértice para o JOGL. Esses buffers são grandes e são substituídos várias vezes durante a vida útil do aplicativo. A memória não é desalocada no tempo e estou ficando ...
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 ...
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 = ...
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 ...