com.mysql.cj.protocol.x

Class SyncMessageReader.ListenersDispatcher

java.lang.Object

com.mysql.cj.protocol.x.SyncMessageReader.ListenersDispatcher

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SyncMessageReader

private class SyncMessageReader.ListenersDispatcher
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private static long	POLL_TIMEOUT The timeout value for queue.poll(timeout, unit) defining the time after which we close and unregister the dispatching thread.
(package private) boolean	started

Constructor Summary

Constructors

Constructor and Description
ListenersDispatcher()

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

POLL_TIMEOUT

private static final long POLL_TIMEOUT

The timeout value for queue.poll(timeout, unit) defining the time after which we close and unregister the dispatching thread. On the other hand, a bigger timeout value allows us to keep dispatcher thread running while multiple concurrent asynchronous read operations are pending, thus avoiding the delays for new dispatching threads creation.

See Also:

Constant Field Values

started

boolean started

Constructor Detail

ListenersDispatcher

public ListenersDispatcher()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable