public class MultiThreadSyncChannel extends Object implements RequestChannel
RequestChannel
in order to group the
requests. It allows best performances with multiples senders.Modifier and Type | Class and Description |
---|---|
private static class |
MultiThreadSyncChannel.SyncRound |
Modifier and Type | Field and Description |
---|---|
private RequestChannel |
channel
The related RequestChannel.
|
private MultiThreadSyncChannel.SyncRound |
currentRound
Synchronization round.
|
private int |
multiThreadSyncDelay
The maximum time the threads hang if 'multiThreadSync' is true.
|
private int |
multiThreadSyncThreshold
The maximum numbers of threads that hang if 'multiThreadSync' is true.
|
private Vector |
syncRequests
Synchronized requests.
|
Constructor and Description |
---|
MultiThreadSyncChannel(RequestChannel rc,
int delay,
int threshold) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
closing() |
void |
connect() |
Identity |
getIdentity() |
AbstractJmsReply |
receive() |
void |
send(AbstractJmsRequest request) |
void |
setTimer(Timer timer) |
private MultiThreadSyncChannel.SyncRound currentRound
private Vector syncRequests
private int multiThreadSyncDelay
private int multiThreadSyncThreshold
private RequestChannel channel
MultiThreadSyncChannel(RequestChannel rc, int delay, int threshold)
public void send(AbstractJmsRequest request) throws Exception
send
in interface RequestChannel
Exception
public void setTimer(Timer timer)
setTimer
in interface RequestChannel
public void connect() throws Exception
connect
in interface RequestChannel
Exception
public AbstractJmsReply receive() throws Exception
receive
in interface RequestChannel
Exception
public void close()
close
in interface RequestChannel
public void closing()
closing
in interface RequestChannel
public Identity getIdentity()
getIdentity
in interface RequestChannel
Copyright © 2020 ScalAgent D.T.. All rights reserved.