先说下思路，为了让任务一次执行，需要定义一个队列，以及一个正在执行的标志。
        任务来了之后，首先是判断当前队列是否为空，如果队列为空，或者正在执行，则加入队列中。否则直接执行处理。
        处理任务的过程中，需要将标记置为执行中，执行完成需要将标记置为执行完成，并且调用执行方法，传个空值。接收到空值之后，则去取队列下个任务，并且执行；如果队列为空，则停止执行，并将正在执行标志置为false。

class SpeakQueue {
    // 是否正在播放
    private var speaking: Boolean = false

    // 创建队列
    private var mesQueue: Queue<String>? = null

    /**
     * 监听RabbitMQ
     */
    fun listenQueue(context: Context) {
        mesQueue = LinkedBlockingQueue<String>(10000)
        RabbitMQUtil.getInstance().receiveQueueMessage("00", object : RabbitMQUtil.ReceiveMessageListener {
            override fun receiveMessage(message: String?) {
                Log.d("消息：", message)
                // 这里开始进行队列插入或者执行操作
                speakMessage(message.toString(), context)
            }
        })
    }

    /**
     * 判断加入队列还是直接执行
     */
    fun speakMessage(callMessage: String, context: Context) {
        if (speaking || !mesQueue!!.isEmpty()) {
            // 正在执行操作或者队列不为空，则插入队列
            mesQueue!!.offer(callMessage)
        } else {
            // 已经结束操作，则开始下一个操作
            speak(callMessage, context)
        }
    }

    /**
     * 主逻辑代码
     */
    fun speak(refText: String, context: Context) {
        if (!TextUtils.isEmpty(refText)) {
            speaking = true
            object : Thread() {
                override fun run() {
                    super.run()
                    try {
                        //休眠3秒
                        sleep(1000)
                    } catch (e: InterruptedException) {
                        e.printStackTrace()
                    }
                    /**
                     * 要执行的操作
                     */
                    runOnUiThread {
                        Log.d("消息222：", refText)
                        showToast(context, "我就是一条消息")
                        speaking = false

                        object : Thread() {
                            override fun run() {
                                super.run()
                                try {
                                    sleep(1000) //休眠3秒
                                } catch (e: InterruptedException) {
                                    e.printStackTrace()
                                }
                                /**
                                 * 要执行的操作
                                 */
                                runOnUiThread {
                                    Log.d("消息333：", refText)
                                    //当前播放完毕，则给个空，从消息队列取消息执行
                                    speak("", context)
                                }
                            }
                        }.start()
                    }
                }
            }.start()
        } else {
            val callMessage: String? = mesQueue!!.poll()
            if (callMessage != null) {
                //获取消息，并且执行
                speak(callMessage, context)
            } else {
                //消息为空，则认为执行完了
                speaking = false
            }
        }
    }

}