Diff: dcs-sdk-java-master/app/src/main/java/com/baidu/duer/dcs/framework/DcsResponseDispatcher.java

Revision:

45:2aa9f933c8d2

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dcs-sdk-java-master/app/src/main/java/com/baidu/duer/dcs/framework/DcsResponseDispatcher.java	Tue Jul 18 16:34:48 2017 +0800
@@ -0,0 +1,96 @@
+/*
+ * Copyright (c) 2017 Baidu, Inc. All Rights Reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.baidu.duer.dcs.framework;
+
+import com.baidu.duer.dcs.framework.dispatcher.AudioData;
+import com.baidu.duer.dcs.framework.dispatcher.DcsResponseBodyEnqueue;
+import com.baidu.duer.dcs.framework.dispatcher.WithDialogIdBlockThread;
+import com.baidu.duer.dcs.framework.dispatcher.WithoutDialogIdBlockThread;
+import com.baidu.duer.dcs.framework.message.DcsResponseBody;
+
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingDeque;
+
+/**
+ * response调度中心，带有dialogRequestId directives按照顺序执行，对于speak指令播报完才执行下一个指令；
+ * 设备端收到不带dialogRequestId的directives立即执行
+ * <p>
+ * Created by wuruisheng on 2017/6/1.
+ */
+public class DcsResponseDispatcher {
+    private final WithDialogIdBlockThread withDialogIdBlockThread;
+    private final WithoutDialogIdBlockThread withoutDialogIdBlockThread;
+    private final BlockingQueue<DcsResponseBody> dependentQueue;
+    private final BlockingQueue<DcsResponseBody> independentQueue;
+    private final DcsResponseBodyEnqueue dcsResponseBodyEnqueue;
+    private final IDcsResponseHandler responseHandler;
+
+    public DcsResponseDispatcher(final DialogRequestIdHandler dialogRequestIdHandler,
+                                 final IDcsResponseHandler responseHandler) {
+        this.responseHandler = responseHandler;
+        dependentQueue = new LinkedBlockingDeque<>();
+        independentQueue = new LinkedBlockingDeque<>();
+        dcsResponseBodyEnqueue = new DcsResponseBodyEnqueue(dialogRequestIdHandler, dependentQueue,
+                independentQueue);
+
+        withDialogIdBlockThread = new WithDialogIdBlockThread(dependentQueue, responseHandler,
+                "withDialogIdBlockThread");
+        withoutDialogIdBlockThread = new WithoutDialogIdBlockThread(independentQueue, responseHandler,
+                "withoutDialogIdBlockThread");
+        withDialogIdBlockThread.start();
+        withoutDialogIdBlockThread.start();
+    }
+
+    public void interruptDispatch() {
+        // 先清空队列，比如播放一首歌：speak+play指令组合的方式，在speak播报过程中进行打断，play就不需要执行了
+        withDialogIdBlockThread.clear();
+        // 让其处于等待新的指令处理
+        unBlockDependentQueue();
+    }
+
+    public void blockDependentQueue() {
+        withDialogIdBlockThread.block();
+    }
+
+    public void unBlockDependentQueue() {
+        withDialogIdBlockThread.unblock();
+    }
+
+    public void onResponseBody(DcsResponseBody responseBody) {
+        dcsResponseBodyEnqueue.handleResponseBody(responseBody);
+    }
+
+    public void onAudioData(AudioData audioData) {
+        dcsResponseBodyEnqueue.handleAudioData(audioData);
+    }
+
+    public void onParseFailed(String unParseMessage) {
+        if (responseHandler != null) {
+            responseHandler.onParseFailed(unParseMessage);
+        }
+    }
+
+    public void release() {
+        withDialogIdBlockThread.stopThread();
+        withoutDialogIdBlockThread.stopThread();
+    }
+
+    public interface IDcsResponseHandler {
+        void onResponse(DcsResponseBody responseBody);
+
+        void onParseFailed(String unParseMessage);
+    }
+}