如何在 TPL 中停止播放并返回正确的值？

Question

在我的 TPL 应用程序中，我想通过 PlayTTS(string text) 方法播放文本到语音。

public static CancellationTokenSource cTokenSource = new CancellationTokenSource();
public static CancellationToken cToken = cTokenSource.Token;

然后在消费者方法中。

async Task Consumer()
    {
        try
        {
            var executionDataflowBlockOptions = new ExecutionDataflowBlockOptions
            {
                MaxDegreeOfParallelism = 50,
                CancellationToken = cToken
            };
            var consumerBlock = new ActionBlock<AppointmentReminder>(
            remainder =>
            {
               if (cToken.IsCancellationRequested)
                  return;
                Dictionary<string, string> dict = new OutboundDial(ts).RunScript(remainder, cToken);
                // update UI by the returned dictionary
            },
            executionDataflowBlockOptions);

            m_bufferBlock.LinkTo(
            consumerBlock, new DataflowLinkOptions { PropagateCompletion = true });
            await consumerBlock.Completion;
        }

我有一个按钮事件来取消进程（WPF）。

private void Cancel_Click(object sender, RoutedEventArgs e)
{
    cTokenSource.Cancel();
}

您会看到ActionBlock 中有cToken.IsCancellationRequested，但是尽管我传入了取消令牌，但它并没有帮助在方法OutboundDial(ts).RunScript(remainder, cToken); 中停止进程。

现在我们来看RunScript的方法。

public Dictionary<string, string> RunScript(AppointmentReminder callData, CancellationToken cToken)
    {
        try
        {
             m_ChannelResource = m_TelephonyServer.GetChannel() as SipChannel;
             m_VoiceResource = m_ChannelResource.VoiceResource;
             // Many logging
             // Dial out

            MakeTest(callData, cToken);
        }
        catch
         {throw;}
        finally
        {
            // destroy m_ChannelResource and m_VoiceResource
         }
        return dict;
    }

关键是方法MakeTest，里面有PlayTTS;

public void MakeTest(AppointmentReminder callData, CancellationToken cToken)
{
    try
    {
        if (!cToken.IsCancellationRequested)
        {
            m_VoiceResource.PlayTTS(callData.Text);  
        }
        else
        {
            cToken.ThrowIfCancellationRequested();
            m_VoiceResource.Stop(); // Stops any current activity on m_VoiceResource.
            dict["ConnectedTime"] = " no connection";
            dict["DialingResult"] = " cancellation";
        }

当我单击取消按钮时，我当前的代码没有到达m_VoiceResource.Stop() 部分。 所以我的问题是当cTokenSource.Cancel();，如何让代码运行在：

m_VoiceResource.Stop(); // Stops any current activity on m_VoiceResource.
dict["ConnectedTime"] = " no connection";
dict["DialingResult"] = " cancellation";

编辑：2014 年 10 月 31 日下午 1:10

根据Servy的评论，我使用了cToken.Register(() => m_VoiceResource.Stop());

我在OneDrive 创建了一个类似的演示。

Answer 1

最后我在 Microsoft MVP 的帮助下找到了解决方案。 Servy 的解决方案很漂亮，但有缺陷。

cToken.Register(() => m_VoiceResource.Stop());

注册应该放在开始播放之前而不是之后。

编辑： 2014 年 11 月 10 日上午 8:09

一个更好的：

 cToken.Register(() => m_VoiceResource.Stop());
 return;

Answer 2

在您检查令牌是否已取消并开始播放后，您将取消令牌。您永远不会返回并再次执行该条件以停止。

你需要做的只是注册一个回调到令牌的取消来停止播放器：

cToken.Register(() => m_VoiceResource.Stop());

在您开始游戏后立即添加该注册。