public class ConcurrentJarCreator
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private static class |
ConcurrentJarCreator.DeferredSupplier |
Modifier and Type | Field and Description |
---|---|
private org.apache.commons.compress.archivers.zip.ScatterZipOutputStream |
directories |
private org.apache.commons.compress.archivers.zip.ScatterZipOutputStream |
manifest |
private org.apache.commons.compress.archivers.zip.ScatterZipOutputStream |
metaInfDir |
private org.apache.commons.compress.archivers.zip.ParallelScatterZipCreator |
parallelScatterZipCreator |
private org.apache.commons.compress.archivers.zip.ScatterZipOutputStream |
synchronousEntries |
private long |
zipCloseElapsed |
Constructor and Description |
---|
ConcurrentJarCreator(int nThreads) |
Modifier and Type | Method and Description |
---|---|
void |
addArchiveEntry(org.apache.commons.compress.archivers.zip.ZipArchiveEntry zipArchiveEntry,
org.apache.commons.compress.parallel.InputStreamSupplier source,
boolean addInParallel)
Adds an archive entry to this archive.
|
static org.apache.commons.compress.archivers.zip.ScatterZipOutputStream |
createDeferred(org.apache.commons.compress.parallel.ScatterGatherBackingStoreSupplier scatterGatherBackingStoreSupplier) |
private org.apache.commons.compress.parallel.InputStreamSupplier |
createInputStreamSupplier(java.io.InputStream payload) |
java.lang.String |
getStatisticsMessage()
Returns a message describing the overall statistics of the compression run
|
void |
writeTo(org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream targetStream) |
private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream directories
private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream metaInfDir
private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream manifest
private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream synchronousEntries
private final org.apache.commons.compress.archivers.zip.ParallelScatterZipCreator parallelScatterZipCreator
private long zipCloseElapsed
public ConcurrentJarCreator(int nThreads) throws java.io.IOException
java.io.IOException
public static org.apache.commons.compress.archivers.zip.ScatterZipOutputStream createDeferred(org.apache.commons.compress.parallel.ScatterGatherBackingStoreSupplier scatterGatherBackingStoreSupplier) throws java.io.IOException
java.io.IOException
public void addArchiveEntry(org.apache.commons.compress.archivers.zip.ZipArchiveEntry zipArchiveEntry, org.apache.commons.compress.parallel.InputStreamSupplier source, boolean addInParallel) throws java.io.IOException
zipArchiveEntry
- The entry to add. Compression methodsource
- The source input stream supplieraddInParallel
- Indicates if the entry should be add in parallel.
If set to false
the entry is added synchronously.java.io.IOException
private org.apache.commons.compress.parallel.InputStreamSupplier createInputStreamSupplier(java.io.InputStream payload)
public void writeTo(org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream targetStream) throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.io.IOException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public java.lang.String getStatisticsMessage()