processing.MQTTEndUser

Class ThreadPool

java.lang.Object

processing.MQTTEndUser.ThreadPool

public class ThreadPool
extends java.lang.Object

9/5/2013 A thread pool that stores available subscribe/publish threads for use. Subscriber: Matlab would like to subscribe a topic from broker, it usually consists of raw data. Publisher: Matlab would like to publish a topic to broker, it usually consists of calculated result data.

Author:

yute

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Hashtable<java.lang.String,MQTTSubscriber>	subscriberTable

Constructor Summary

Constructors

Constructor and Description
ThreadPool()

Method Summary

Methods

Modifier and Type	Method and Description
int	availablePublisher()
int	availableSubscriber()
MQTTSubscriber	getSubscriber(java.lang.String ipandport, java.lang.String threadName, java.lang.String topic, int qos)
boolean	returnSubscriberThreadToPool(MQTTSubscriber t)

Methods inherited from class java.lang.Object

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

Field Detail

subscriberTable

public java.util.Hashtable<java.lang.String,MQTTSubscriber> subscriberTable

Constructor Detail

ThreadPool

public ThreadPool()

Method Detail

getSubscriber

public MQTTSubscriber getSubscriber(java.lang.String ipandport,
                           java.lang.String threadName,
                           java.lang.String topic,
                           int qos)

returnSubscriberThreadToPool

public boolean returnSubscriberThreadToPool(MQTTSubscriber t)

Parameters:

t, - a returned thread

Returns:

true:ok, false:return sth weird

availableSubscriber

public int availableSubscriber()

availablePublisher

public int availablePublisher()