Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
JDK 17 jdk.internal.le.jmod - Internal Line Editing Module
JDK 17 jdk.internal.le.jmod is the JMOD file for JDK 17 Internal Line Editing module.
JDK 17 Internal Line Editing module compiled class files are stored in \fyicenter\jdk-17.0.5\jmods\jdk.internal.le.jmod.
JDK 17 Internal Line Editing module compiled class files are also linked and stored in the \fyicenter\jdk-17.0.5\lib\modules JImage file.
JDK 17 Internal Line Editing module source code files are stored in \fyicenter\jdk-17.0.5\lib\src.zip\jdk.internal.le.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ jdk/internal/org/jline/utils/NonBlockingPumpReader.java
/* * Copyright (c) 2002-2017, the original author or authors. * * This software is distributable under the BSD license. See the terms of the * BSD license in the documentation provided with this software. * * https://opensource.org/licenses/BSD-3-Clause */ package jdk.internal.org.jline.utils; import java.io.IOException; import java.io.InterruptedIOException; import java.io.Writer; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.ReentrantLock; public class NonBlockingPumpReader extends NonBlockingReader { private static final int DEFAULT_BUFFER_SIZE = 4096; private final char[] buffer; private int read; private int write; private int count; /** Main lock guarding all access */ final ReentrantLock lock; /** Condition for waiting takes */ private final Condition notEmpty; /** Condition for waiting puts */ private final Condition notFull; private final Writer writer; private boolean closed; public NonBlockingPumpReader() { this(DEFAULT_BUFFER_SIZE); } public NonBlockingPumpReader(int bufferSize) { this.buffer = new char[bufferSize]; this.writer = new NbpWriter(); this.lock = new ReentrantLock(); this.notEmpty = lock.newCondition(); this.notFull = lock.newCondition(); } public Writer getWriter() { return this.writer; } @Override public boolean ready() { return available() > 0; } public int available() { final ReentrantLock lock = this.lock; lock.lock(); try { return count; } finally { lock.unlock(); } } @Override protected int read(long timeout, boolean isPeek) throws IOException { final ReentrantLock lock = this.lock; lock.lock(); try { // Blocks until more input is available or the reader is closed. if (!closed && count == 0) { try { if (timeout > 0L) { notEmpty.await(timeout, TimeUnit.MILLISECONDS); } else { notEmpty.await(); } } catch (InterruptedException e) { throw (IOException) new InterruptedIOException().initCause(e); } } if (closed) { return EOF; } else if (count == 0) { return READ_EXPIRED; } else { if (isPeek) { return buffer[read]; } else { int res = buffer[read]; if (++read == buffer.length) { read = 0; } --count; notFull.signal(); return res; } } } finally { lock.unlock(); } } @Override public int readBuffered(char[] b) throws IOException { if (b == null) { throw new NullPointerException(); } else if (b.length == 0) { return 0; } else { final ReentrantLock lock = this.lock; lock.lock(); try { if (!closed && count == 0) { try { notEmpty.await(); } catch (InterruptedException e) { throw (IOException) new InterruptedIOException().initCause(e); } } if (closed) { return EOF; } else if (count == 0) { return READ_EXPIRED; } else { int r = Math.min(b.length, count); for (int i = 0; i < r; i++) { b[i] = buffer[read++]; if (read == buffer.length) { read = 0; } } count -= r; notFull.signal(); return r; } } finally { lock.unlock(); } } } void write(char[] cbuf, int off, int len) throws IOException { if (len > 0) { final ReentrantLock lock = this.lock; lock.lock(); try { while (len > 0) { // Blocks until there is new space available for buffering or the // reader is closed. if (!closed && count == buffer.length) { try { notFull.await(); } catch (InterruptedException e) { throw (IOException) new InterruptedIOException().initCause(e); } } if (closed) { throw new IOException("Closed"); } while (len > 0 && count < buffer.length) { buffer[write++] = cbuf[off++]; count++; len--; if (write == buffer.length) { write = 0; } } notEmpty.signal(); } } finally { lock.unlock(); } } } @Override public void close() throws IOException { final ReentrantLock lock = this.lock; lock.lock(); try { this.closed = true; this.notEmpty.signalAll(); this.notFull.signalAll(); } finally { lock.unlock(); } } private class NbpWriter extends Writer { @Override public void write(char[] cbuf, int off, int len) throws IOException { NonBlockingPumpReader.this.write(cbuf, off, len); } @Override public void flush() throws IOException { } @Override public void close() throws IOException { NonBlockingPumpReader.this.close(); } } }
⏎ jdk/internal/org/jline/utils/NonBlockingPumpReader.java
Or download all of them as a single archive file:
File name: jdk.internal.le-17.0.5-src.zip File size: 231458 bytes Release date: 2022-09-13 Download
⇒ JDK 17 jdk.internal.opt.jmod - Internal Opt Module
⇐ JDK 17 jdk.internal.jvmstat.jmod - Internal JVM Stat Module
2023-08-25, 4629👍, 0💬
Popular Posts:
commons-fileupload-1.3.3 -sources.jaris the source JAR file for Apache Commons FileUpload 1.3., whic...
JDK 11 jdk.httpserver.jmod is the JMOD file for JDK 11 HTTP Server module. JDK 11 HTTP Server module...
Commons VFS provides a single API for accessing various different file systems. It presents a unifor...
JDK 6 tools.jar is the JAR file for JDK 6 tools. It contains Java classes to support different JDK t...
Provides support for the runtime platform, core utility methods and the extension registry. JAR File...