package org.classpath.icedtea.plugin;

import sun.applet.PluginException;
import sun.applet.PluginStreamHandler;

class PluginMessageHandlerWorker extends Thread {

	private boolean free = true;
	private int id;
	private String message = null;
	PluginStreamHandler streamHandler = null;
	
	public PluginMessageHandlerWorker(PluginStreamHandler streamHandler, int id) {
		this.id = id;
		this.streamHandler = streamHandler;
	}

	public void setmessage(String message) {
		this.message = message;
	}

	public void run() {
		while (true) {

			if (message != null) {
				
				// ideally, whoever returns things object should mark it 
				// busy first, but just in case..
				busy();
				System.err.println("Thread " + id + " picking up " + message + " from queue...");

				try {
					streamHandler.handleMessage(message);
				} catch (PluginException pe) {
					/*
					   catch the exception and DO NOTHING. The plugin should take over after 
					   this error and let the user know. We don't quit because otherwise the 
					   exception will spread to the rest of the applets which is a no-no
					 */ 
				}

				this.message = null;
			} else {
				
				// Sleep when there is nothing to do
				try {
					Thread.sleep(Integer.MAX_VALUE);
					System.err.println("Consumer thread " + id + " sleeping...");
				} catch (InterruptedException ie) {
					System.err.println("Consumer thread " + id + " woken...");
					// nothing.. someone woke us up, see if there 
					// is work to do
				}
			}
			
			// mark ourselves free again
			free();
		}
	}
	
	
	
	public int getWorkerId() {
		return id;
	}

	public void busy() {
		this.free = false;
	}

	
	public void free() {
		this.free = true;
	}
	
	public boolean isFree() {
		return free;
	}
}