org.codehaus.plexus.archiver.zip

Class ConcurrentJarCreator

java.lang.Object

org.codehaus.plexus.archiver.zip.ConcurrentJarCreator

public class ConcurrentJarCreator
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ConcurrentJarCreator.DeferredSupplier

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
ConcurrentJarCreator(int nThreads)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

directories

private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream directories

metaInfDir

private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream metaInfDir

manifest

private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream manifest

synchronousEntries

private final org.apache.commons.compress.archivers.zip.ScatterZipOutputStream synchronousEntries

parallelScatterZipCreator

private final org.apache.commons.compress.archivers.zip.ParallelScatterZipCreator parallelScatterZipCreator

zipCloseElapsed

private long zipCloseElapsed

Constructor Detail

ConcurrentJarCreator

public ConcurrentJarCreator(int nThreads)
                     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createDeferred

public static org.apache.commons.compress.archivers.zip.ScatterZipOutputStream createDeferred(org.apache.commons.compress.parallel.ScatterGatherBackingStoreSupplier scatterGatherBackingStoreSupplier)
                                                                                       throws java.io.IOException

Throws:

java.io.IOException

addArchiveEntry

public void addArchiveEntry(org.apache.commons.compress.archivers.zip.ZipArchiveEntry zipArchiveEntry,
                            org.apache.commons.compress.parallel.InputStreamSupplier source,
                            boolean addInParallel)
                     throws java.io.IOException

Adds an archive entry to this archive.

This method is expected to be called from a single client thread

Parameters:

zipArchiveEntry - The entry to add. Compression method

source - The source input stream supplier

addInParallel - Indicates if the entry should be add in parallel. If set to false the entry is added synchronously.

Throws:

java.io.IOException

createInputStreamSupplier

private org.apache.commons.compress.parallel.InputStreamSupplier createInputStreamSupplier(java.io.InputStream payload)

writeTo

public void writeTo(org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream targetStream)
             throws java.io.IOException,
                    java.util.concurrent.ExecutionException,
                    java.lang.InterruptedException

Throws:

java.io.IOException

java.util.concurrent.ExecutionException

java.lang.InterruptedException

getStatisticsMessage

public java.lang.String getStatisticsMessage()

Returns a message describing the overall statistics of the compression run

Returns:

A string