com.emc.atmos

Class StickyThreadAlgorithm

java.lang.Object

com.emc.atmos.StickyThreadAlgorithm

All Implemented Interfaces:

LoadBalancingAlgorithm

public class StickyThreadAlgorithm
extends java.lang.Object
implements LoadBalancingAlgorithm

This implementation will tie a specific endpoint to each thread to avoid MDS sync issues. However, multiple threads will be distributed between the configured endpoints.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	callCount
protected java.lang.ThreadLocal<java.net.URI>	threadEndpoint

Constructor Summary

Constructors

Constructor and Description
StickyThreadAlgorithm()

Method Summary

Methods

Modifier and Type	Method and Description
java.net.URI	getNextEndpoint(java.net.URI[] endpoints)

Methods inherited from class java.lang.Object

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

Field Detail

threadEndpoint

protected java.lang.ThreadLocal<java.net.URI> threadEndpoint

callCount

protected int callCount

Constructor Detail

StickyThreadAlgorithm

public StickyThreadAlgorithm()

Method Detail

getNextEndpoint

public java.net.URI getNextEndpoint(java.net.URI[] endpoints)

Specified by:

getNextEndpoint in interface LoadBalancingAlgorithm