producer.java

短信发送

/**
 * Created at Nov 30, 2008
 */
package com.jdev.util.samples;

import com.jdev.util.Consumer;
import com.jdev.util.VectorQueue;

/**
 * <p>Title: Producer</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 
 */
public class Producer implements Runnable {
	Consumer consumer = new SubConsumer();
	
	/* (non-Javadoc)
	 * @see java.lang.Runnable#run()
	 */
	public void run() {
		consumer.init();
		consumer.setName(this.getClass().toString());
		consumer.setQueue(new VectorQueue());
		consumer.add(new Integer(0));
		
		int i = 0;
		while(true)
		{
         Integer next = new Integer(i++);
         consumer.add(next);
         try
         {
            Thread.currentThread().sleep(1000);
         }
         catch (Exception e)
         {
         }
		}
	}

	public static void main(String[] args) {
		Thread s = new Thread(new Producer());
		s.start();
	}
}