freettsemacspeakhandler.java

使用Exlipse编写的一个语音程序

/**
 * Copyright 2001 Sun Microsystems, Inc.
 * 
 * See the file "license.terms" for information on usage and
 * redistribution of this file, and for a DISCLAIMER OF ALL 
 * WARRANTIES.
 */

import com.sun.speech.freetts.Voice;

import com.sun.speech.freetts.util.Utilities;
import java.net.Socket;
import java.util.Vector;


/**
 * Implements a simplified version of the Emacspeak speech server.
 */
public class FreeTTSEmacspeakHandler extends EmacspeakProtocolHandler {

    private SpeakCommandHandler speakCommandHandler;


    /**
     * Constructs a Emacspeak ProtocolHandler
     *
     * @param freetts the FreeTTS that this FreeTTSEmacspeakHandler belongs
     * @param socket the Socket that holds the TCP connection
     */
    public FreeTTSEmacspeakHandler(Socket socket, Voice voice) {
	setSocket(socket);
	this.speakCommandHandler = new SpeakCommandHandler(voice);
	this.speakCommandHandler.start();
	setDebug(Utilities.getBoolean("debug"));
    }


    /**
     * Speaks the given input text.
     *
     * @param input the input text to speak.
     */
    public void speak(String input) {
	// split around "[*]"
	String[] parts = input.split(PARENS_STAR_REGEX);
	for (int i = 0; i < parts.length; i++) {
	    speakCommandHandler.add(parts[i]);
	}
    }


    /**
     * Removes all the queued text.
     */
    public void cancelAll() {
        speakCommandHandler.removeAll();
    }


    /**
     * Sets the speaking rate.
     *
     * @param wpm the new speaking rate (words per minute)
     */
    public void setRate(float wpm) {
        speakCommandHandler.setRate(wpm);
    }
    
    
    /**
     * This thread is used to separate the handling of Voice.speak() from
     * the thread that accepts commands from the client, so that the 
     * latter won't be blocked by the former.
     */
    class SpeakCommandHandler extends Thread {
        
        private Voice voice;
        private boolean done = false;
        private Vector commandList = new Vector();
        
        
        /**
         * Constructs a default SpeakCommandHandler object.
         *
         * @param voice the Voice object use to speak
         */
        public SpeakCommandHandler(Voice voice) {
            this.voice = voice;
        }
        
        
        /**
         * Implements the run() method of the Thread class.
         */
        public void run() {
            while (!getSocket().isClosed() || commandList.size() > 0) {
                Object firstCommand = null;
                synchronized (commandList) {
                    while (commandList.size() == 0 &&
                           !getSocket().isClosed()) {
                        try {
                            commandList.wait();
                        } catch (InterruptedException ie) {
                            ie.printStackTrace();
                        }
                    }
                    if (commandList.size() > 0) {
                        firstCommand = commandList.remove(0);
                    }
                }
                if (firstCommand != null) {
                    voice.speak((String) firstCommand);
                    debugPrintln("SPEAK: \"" + firstCommand + "\"");
                }
            }
            debugPrintln("SpeakCommandHandler: thread terminated");
        }
        
        
        /**
         * Adds the given command to this Handler.
         *
         * @param command the text to be spoken
         */
        public void add(String command) {
            synchronized (commandList) {
                commandList.add(command);
                commandList.notifyAll();
            }
        }
    
    
        /**
         * Removes all the commands from this Handler.
         */
        public void removeAll() {
            synchronized (commandList) {
                voice.getAudioPlayer().cancel();
                commandList.removeAllElements();
            }
        }
        
        
        /**
         * Sets the speaking rate.
         *
         * @param wpm the new speaking rate (words per minute)
         */
        public void setRate(float wpm) {
            voice.setRate(wpm);
        }
        
        
        /**
         * Terminates this SpeakCommandHandler thread.
         *
         * @param done true to terminate this thread
         */
        public synchronized void setDone(boolean done) {
            this.done = done;
        }
    }
}