org.apache.shardingsphere.shardingproxy.frontend.executor

Class ChannelThreadExecutorGroup

java.lang.Object

org.apache.shardingsphere.shardingproxy.frontend.executor.ChannelThreadExecutorGroup

public final class ChannelThreadExecutorGroup
extends Object

Channel thread executor group.

Manage the thread for each channel invoking. This ensure XA transaction framework processed by current thread id.

Author:

zhaojun, zhangliang

Constructor Summary

Constructors

Constructor and Description
ChannelThreadExecutorGroup()

Method Summary

Modifier and Type	Method and Description
ExecutorService	get(io.netty.channel.ChannelId channelId) Get executor service of current channel.
static ChannelThreadExecutorGroup	getInstance() Get channel thread executor group.
void	register(io.netty.channel.ChannelId channelId) Register channel.
void	unregister(io.netty.channel.ChannelId channelId) Unregister channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelThreadExecutorGroup

public ChannelThreadExecutorGroup()

Method Detail

getInstance

public static ChannelThreadExecutorGroup getInstance()

Get channel thread executor group.

Returns:

channel thread executor group

register

public void register(io.netty.channel.ChannelId channelId)

Register channel.

Parameters:

channelId - channel id

get

public ExecutorService get(io.netty.channel.ChannelId channelId)

Get executor service of current channel.

Parameters:

channelId - channel id

Returns:

executor service of current channel

unregister

public void unregister(io.netty.channel.ChannelId channelId)

Unregister channel.

Parameters:

channelId - channel id