void function ( ) { final Throwable loc0 = this . ex . get ( ) ; if ( loc0 != null ) { if ( loc0 instanceof Error ) throw ( Error ) loc0 ; if ( loc0 instanceof RuntimeException ) throw ( RuntimeException ) loc0 ; else throw new RuntimeException ( loc0 ) ; } }
checks to see if an exception has been raised in the writer thread and if so rethrows it as an error or runtimeexception as appropriate . concode_field_sep AtomicBoolean isClosed concode_elem_sep int threadsCreated concode_elem_sep int DEFAULT_QUEUE_SIZE concode_elem_sep AtomicReference<Throwable> ex concode_elem_sep Thread writer concode_elem_sep WriterRunnable writerRunnable concode_elem_sep BlockingQueue<T> queue concode_field_sep String getThreadNamePrefix concode_elem_sep void synchronouslyWrite concode_elem_sep void run concode_elem_sep void write concode_elem_sep void close concode_elem_sep void synchronouslyClose