Package io.debezium.relational

Class RelationalSnapshotChangeEventSource.ThreadedSnapshotExecutor

java.lang.Object

io.debezium.relational.RelationalSnapshotChangeEventSource.ThreadedSnapshotExecutor

All Implemented Interfaces:

AutoCloseable

Enclosing class:

RelationalSnapshotChangeEventSource<P extends Partition,O extends OffsetContext>

private static class RelationalSnapshotChangeEventSource.ThreadedSnapshotExecutor
extends Object
implements AutoCloseable

Manages threaded execution of snapshot work using a thread pool.

Field Summary

Fields

Modifier and Type	Field	Description
private final CompletionService<Void>	completionService
private final ExecutorService	executorService
private int	submittedTasks

Constructor Summary

Constructors

Constructor	Description
ThreadedSnapshotExecutor(int threadCount, String description)

Method Summary

Modifier and Type	Method	Description
(package private) void	awaitCompletion()
void	close()
(package private) void	submit(Callable<Void> task)

Methods inherited from class java.lang.Object

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

Field Details

executorService

private final ExecutorService executorService

completionService

private final CompletionService<Void> completionService

submittedTasks

private int submittedTasks

Constructor Details

ThreadedSnapshotExecutor

ThreadedSnapshotExecutor(int threadCount,
 String description)

Method Details

submit

void submit(Callable<Void> task)

awaitCompletion

void awaitCompletion()
              throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

close

public void close()

Specified by:

close in interface AutoCloseable