j2se.MQTTFogServer

Class ThreadPool

java.lang.Object

j2se.MQTTFogServer.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,MQTTPublisher>	publisherTable
java.util.Hashtable<java.lang.String,MQTTSubscriber>	subscriberTable
java.util.Hashtable<java.lang.String,j2se.MQTTFogServer.RandomDataThread>	threadTable

Constructor Summary

Constructors

Constructor and Description
ThreadPool()

Method Summary

Methods

Modifier and Type	Method and Description
int	availablePublisher()
int	availableSubscriber()
MQTTPublisher	getPublisher(java.lang.String ipandport, java.lang.String threadName, java.lang.String topic, int qos)
MQTTSubscriber	getSubscriber(java.lang.String ipandport, java.lang.String threadName, java.lang.String topic, int qos)
j2se.MQTTFogServer.RandomDataThread	getThread(java.lang.String threadName)
boolean	returnPublisherThreadToPool(MQTTPublisher t)
boolean	returnSubscriberThreadToPool(MQTTSubscriber t)
boolean	returnThreadToPool(j2se.MQTTFogServer.RandomDataThread t)

Methods inherited from class java.lang.Object

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

Field Detail

threadTable

public java.util.Hashtable<java.lang.String,j2se.MQTTFogServer.RandomDataThread> threadTable

subscriberTable

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

publisherTable

public java.util.Hashtable<java.lang.String,MQTTPublisher> publisherTable

Constructor Detail

ThreadPool

public ThreadPool()

Method Detail

getThread

public j2se.MQTTFogServer.RandomDataThread getThread(java.lang.String threadName)

Parameters:

threadName -

Returns:

a new thread connecting with Matlab(SIFT), null if threadName has been used

returnThreadToPool

public boolean returnThreadToPool(j2se.MQTTFogServer.RandomDataThread t)

Parameters:

t, - a returned thread

Returns:

true:ok, false:return sth weird

getPublisher

public MQTTPublisher getPublisher(java.lang.String ipandport,
                         java.lang.String threadName,
                         java.lang.String topic,
                         int qos)

returnPublisherThreadToPool

public boolean returnPublisherThreadToPool(MQTTPublisher t)

Parameters:

t, - a returned thread

Returns:

true:ok, false:return sth weird

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()