cmppthread.java

短信网关发送接受平台。

import java.lang.*;

public class CMPPThread extends Thread
{
	private final static int WAIT_COUNT		= 16;
	
	public final static int THREAD_ACCELERATE	= 0;
	public final static int THREAD_RUNNING		= 1;
	public final static int THREAD_DECELERATE	= 2;
	public final static int THREAD_STOPPED		= 3;

	public int m_nStatus = THREAD_STOPPED;
	
	public boolean isRunning()
	{
		if(m_nStatus == THREAD_RUNNING)
		{
			return true;
		}
		
		return false;
	}
	
	public void startup()
	{
		try
		{
			m_nStatus = THREAD_ACCELERATE;
			
			start();
			
			int nCount = WAIT_COUNT;
			while(m_nStatus == THREAD_ACCELERATE && nCount > 0)
			{
				Thread.sleep(1000);
				nCount --;
			}
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
			System.out.println("CMPPThread.startup : unexpected exit !");
		}
	}
	
	public void shutdown()
	{
		try
		{
			if(m_nStatus == THREAD_STOPPED)
			{
				return;
			}
			
			m_nStatus = THREAD_DECELERATE;
		
			int nCount = WAIT_COUNT;
			while(m_nStatus == THREAD_DECELERATE && nCount > 0)
			{
				Thread.sleep(1000);
				nCount --;
			}
			
			stop();
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
			System.out.println("CMPPThread.shutdown : unexpected exit !");
		}
	}
}