java.io.InterruptedIOException#getMessage ( )源码实例Demo

下面列出了java.io.InterruptedIOException#getMessage ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： lavaplayer 文件： LocalAudioTrackExecutor.java

private InterruptedException findInterrupt(Throwable throwable) {
  InterruptedException exception = findDeepException(throwable, InterruptedException.class);

  if (exception == null) {
    InterruptedIOException ioException = findDeepException(throwable, InterruptedIOException.class);

    if (ioException != null && (ioException.getMessage() == null || !ioException.getMessage().contains("timed out"))) {
      exception = new InterruptedException(ioException.getMessage());
    }
  }

  if (exception == null && Thread.interrupted()) {
    return new InterruptedException();
  }

  return exception;
}

源代码2 项目： DoraemonKit 文件： ObsoleteUrlFactory.java

void initOutputStream(final BufferedSink sink, final long expectedContentLength) {
    this.timeout = sink.timeout();
    this.expectedContentLength = expectedContentLength;

    // An output stream that writes to sink. If expectedContentLength is not -1, then this expects
    // exactly that many bytes to be written.
    this.outputStream = new OutputStream() {
        private long bytesReceived;

        @Override
        public void write(int b) throws IOException {
            write(new byte[]{(byte) b}, 0, 1);
        }

        @Override
        public void write(byte[] source, int offset, int byteCount) throws IOException {
            if (closed) throw new IOException("closed"); // Not IllegalStateException!

            if (expectedContentLength != -1L && bytesReceived + byteCount > expectedContentLength) {
                throw new ProtocolException("expected " + expectedContentLength
                        + " bytes but received " + bytesReceived + byteCount);
            }

            bytesReceived += byteCount;
            try {
                sink.write(source, offset, byteCount);
            } catch (InterruptedIOException e) {
                throw new SocketTimeoutException(e.getMessage());
            }
        }

        @Override
        public void flush() throws IOException {
            if (closed) return; // Weird, but consistent with historical behavior.
            sink.flush();
        }

        @Override
        public void close() throws IOException {
            closed = true;

            if (expectedContentLength != -1L && bytesReceived < expectedContentLength) {
                throw new ProtocolException("expected " + expectedContentLength
                        + " bytes but received " + bytesReceived);
            }

            sink.close();
        }
    };
}

源代码3 项目： DoraemonKit 文件： ObsoleteUrlFactory.java

void initOutputStream(final BufferedSink sink, final long expectedContentLength) {
    this.timeout = sink.timeout();
    this.expectedContentLength = expectedContentLength;

    // An output stream that writes to sink. If expectedContentLength is not -1, then this expects
    // exactly that many bytes to be written.
    this.outputStream = new OutputStream() {
        private long bytesReceived;

        @Override
        public void write(int b) throws IOException {
            write(new byte[]{(byte) b}, 0, 1);
        }

        @Override
        public void write(byte[] source, int offset, int byteCount) throws IOException {
            if (closed) throw new IOException("closed"); // Not IllegalStateException!

            if (expectedContentLength != -1L && bytesReceived + byteCount > expectedContentLength) {
                throw new ProtocolException("expected " + expectedContentLength
                        + " bytes but received " + bytesReceived + byteCount);
            }

            bytesReceived += byteCount;
            try {
                sink.write(source, offset, byteCount);
            } catch (InterruptedIOException e) {
                throw new SocketTimeoutException(e.getMessage());
            }
        }

        @Override
        public void flush() throws IOException {
            if (closed) return; // Weird, but consistent with historical behavior.
            sink.flush();
        }

        @Override
        public void close() throws IOException {
            closed = true;

            if (expectedContentLength != -1L && bytesReceived < expectedContentLength) {
                throw new ProtocolException("expected " + expectedContentLength
                        + " bytes but received " + bytesReceived);
            }

            sink.close();
        }
    };
}

方法所在类

java.io.InterruptedIOException