Package org.burningwave.core.concurrent

Class Synchronizer

java.lang.Object

org.burningwave.core.concurrent.Synchronizer

All Implemented Interfaces:

AutoCloseable, Closeable, Identifiable, ManagedLogger

public class Synchronizer
extends Object
implements Closeable, ManagedLogger

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Synchronizer.Mutex

Nested classes/interfaces inherited from interface org.burningwave.core.ManagedLogger

ManagedLogger.Repository

Method Summary

Modifier and Type	Method	Description
void	clear()
void	close()
static Synchronizer	create(String name, boolean undestroyable)
void	execute(String id, Runnable executable)
<T> T	execute(String id, Supplier<T> executable)
<E extends Throwable> void	executeThrower(String id, ThrowingRunnable<E> executable)
<T, E extends Throwable> T	executeThrower(String id, ThrowingSupplier<T,E> executable)
Thread[]	getAllThreads()
String	getAllThreadsInfoAsString(boolean getMutexesInfo)
Synchronizer.Mutex	getMutex(String id)
void	logAllThreadsState(boolean logMutexes)
void	removeIfUnused(Synchronizer.Mutex mutex)
void	startAllThreadsMonitoring(Long interval)
void	stopAllThreadsMonitoring()
void	stopAllThreadsMonitoring(boolean waitThreadToFinish)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.burningwave.core.Closeable

closeResources, closeResources, createCloseResoucesTask, createCloseResoucesTask

Methods inherited from interface org.burningwave.core.Identifiable

getId, getOperationId

Methods inherited from interface org.burningwave.core.ManagedLogger

logDebug, logDebug, logError, logError, logError, logError, logError, logInfo, logInfo, logTrace, logTrace, logWarn, logWarn

Method Details

create

public static Synchronizer create(String name,
boolean undestroyable)

getMutex

public Synchronizer.Mutex getMutex(String id)

removeIfUnused

public void removeIfUnused(Synchronizer.Mutex mutex)

execute

public void execute(String id,
Runnable executable)

executeThrower

public <E extends Throwable> void executeThrower(String id,
ThrowingRunnable<E> executable)
                                          throws E extends Throwable

Throws:

E extends Throwable

execute

public <T> T execute(String id,
Supplier<T> executable)

executeThrower

public <T,
E extends Throwable> T executeThrower(String id,
ThrowingSupplier<T,E> executable)
                                         throws E extends Throwable

Throws:

E extends Throwable

clear

public void clear()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

logAllThreadsState

public void logAllThreadsState(boolean logMutexes)

getAllThreadsInfoAsString

public String getAllThreadsInfoAsString(boolean getMutexesInfo)

getAllThreads

public Thread[] getAllThreads()

startAllThreadsMonitoring

public void startAllThreadsMonitoring(Long interval)

stopAllThreadsMonitoring

public void stopAllThreadsMonitoring()

stopAllThreadsMonitoring

public void stopAllThreadsMonitoring(boolean waitThreadToFinish)