Package org.apache.maven.lifecycle.internal.builder.multithreaded

Class ThreadOutputMuxer

java.lang.Object

org.apache.maven.lifecycle.internal.builder.multithreaded.ThreadOutputMuxer

public class ThreadOutputMuxer
extends java.lang.Object

NOTE: This class is not part of any public api and can be changed or deleted without prior notice. This class in particular may spontaneously self-combust and be replaced by a plexus-compliant thread aware logger implementation at any time.

Since:

3.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ThreadOutputMuxer.ConsolePrinter	A simple but safe solution for printing to the console.
private class	ThreadOutputMuxer.ThreadBoundPrintStream

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Set<ProjectSegment>	completedBuilds
private ProjectSegment	currentBuild
private java.io.ByteArrayOutputStream	defaultOutputStreamForUnknownData
private java.io.PrintStream	defaultPrintStream
private java.io.PrintStream	originalSystemOUtStream
private ThreadOutputMuxer.ConsolePrinter	printer
private java.util.Map<ProjectSegment,java.io.PrintStream>	printStreams
private java.lang.ThreadLocal<ProjectSegment>	projectBuildThreadLocal
private java.util.Iterator<ProjectSegment>	projects
private java.util.Map<ProjectSegment,java.io.ByteArrayOutputStream>	streams

Constructor Summary

Constructors

Constructor	Description
ThreadOutputMuxer(ProjectBuildList segmentChunks, java.io.PrintStream originalSystemOut)

Method Summary

Modifier and Type	Method	Description
void	associateThreadWithProjectSegment(ProjectSegment projectBuild)
void	close()
private void	disconnectThreadFromProject()
private java.io.PrintStream	getThreadBoundPrintStream()
private boolean	ownsRealOutputStream(ProjectSegment projectBuild)
private void	setNext()
void	setThisModuleComplete(ProjectSegment projectBuild)

Methods inherited from class java.lang.Object

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

Field Detail

projects

private final java.util.Iterator<ProjectSegment> projects

projectBuildThreadLocal

private final java.lang.ThreadLocal<ProjectSegment> projectBuildThreadLocal

streams

private final java.util.Map<ProjectSegment,java.io.ByteArrayOutputStream> streams

printStreams

private final java.util.Map<ProjectSegment,java.io.PrintStream> printStreams

defaultOutputStreamForUnknownData

private final java.io.ByteArrayOutputStream defaultOutputStreamForUnknownData

defaultPrintStream

private final java.io.PrintStream defaultPrintStream

completedBuilds

private final java.util.Set<ProjectSegment> completedBuilds

currentBuild

private volatile ProjectSegment currentBuild

originalSystemOUtStream

private final java.io.PrintStream originalSystemOUtStream

printer

private final ThreadOutputMuxer.ConsolePrinter printer

Constructor Detail

ThreadOutputMuxer

public ThreadOutputMuxer(ProjectBuildList segmentChunks,
                         java.io.PrintStream originalSystemOut)

Method Detail

close

public void close()

setNext

private void setNext()

ownsRealOutputStream

private boolean ownsRealOutputStream(ProjectSegment projectBuild)

getThreadBoundPrintStream

private java.io.PrintStream getThreadBoundPrintStream()

associateThreadWithProjectSegment

public void associateThreadWithProjectSegment(ProjectSegment projectBuild)

setThisModuleComplete

public void setThisModuleComplete(ProjectSegment projectBuild)

disconnectThreadFromProject

private void disconnectThreadFromProject()