0

我有一个带有异步 OnSurfaceTextureUpdated 方法的活动（使用 ISurfaceTextureListener），在该方法中我调用异步 SendPixel 方法：

public async void OnSurfaceTextureUpdated(SurfaceTexture surface)
{
    bool sendPixel = false;

    [...]

    if (Settings.Pixel.period >= 0)
    {
        if (stopWatch.ElapsedMilliseconds >= Settings.Pixel.nextSending)
        {
            if (Settings.Pixel.period > 0)
                Settings.Pixel.nextSending += Settings.Pixel.period * ((int)((stopWatch.ElapsedMilliseconds - Settings.Pixel.nextSending) / Settings.Pixel.period) + 1);
            sendPixel = true;
        }
    }

    [...]

    if (sendPixel)
        await SendPixel();
}

这是异步 SendPixel 方法：

async Task SendPixel()
{
    try
    {
        if (Ev3Messaging.IsConnected())
        {
            Color color = new Color(bm.GetPixel(Settings.Camera.viewport.X_VpToCv(Settings.Pixel.x), Settings.Camera.viewport.X_VpToCv(Settings.Pixel.y)));
            Ev3Messaging.AddNumberMessage("MC_Hue", color.GetHue());
            Ev3Messaging.AddNumberMessage("MC_Brightness", color.GetBrightness());
            Console.WriteLine("SendPixel");
            await Ev3Messaging.SendMessages();
            Console.WriteLine("SendPixelEnd");
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine("Error SendPixel: " + ex.Message);
    }
}

ISurfaceTextureListener 读取一个视频流，然后多次调用 SendPixel 方法。问题是控制台很好地显示“SendPixel”，但不显示“SendPixelEnd”，并且没有抛出错误。之后，当我关闭活动时，会显示每个丢失的“SendPixelEnd”。

编辑： EV3Messaging.SendMessages 发送在前几行中添加的消息（通过蓝牙）：

static List<byte> btMessage = new List<byte>();
static public async Task SendMessages()
{
    if (_socket != null)
        await _socket.OutputStream.WriteAsync(btMessage.ToArray(), 0, btMessage.Count);
}

为什么会发生这种情况，我该如何解决？

提前致谢。

PS：对不起我的英语不好^^

4

1 回答 1

1

已解决：每次发送数据时我都忘记清除 btMessage 列表，这会导致这种奇怪的行为。这个问题也可能是因为从蓝牙设备接收数据的方式不好。

那么 SendMessages 方法就变成了：

static public async Task SendMessages()
{
    if (_socket != null)
        await _socket.OutputStream.WriteAsync(btMessage.ToArray(), 0, btMessage.Count);
    btMessage.Clear();
}

因为每次添加消息时，都会在 btMessage 列表的末尾添加新框架。

此外，要获取传入消息，我使用以下代码：

public static void InputMessagesManager(Action<BtMessage> incomingMessageEvent)
{
    _tokenSource = new CancellationTokenSource();
    Task t = Task.Factory.StartNew(async () =>
    {
        Stream inputStream = _socket.InputStream;

        while (!_tokenSource.IsCancellationRequested)
        {
            if (inputStream == null)
                inputStream = _socket.InputStream;
            if (inputStream != null && inputStream.CanRead)
            {
                await inputStream.ReadAsync(_sizeBuffer, 0, _sizeBuffer.Length);

                short size = (short)(_sizeBuffer[0] | _sizeBuffer[1] << 8);
                if (size != 0)
                {
                    byte[] frame = new byte[size];
                    await inputStream.ReadAsync(frame, 0, frame.Length);
                    BtMessage btMes = new BtMessage(frame);
                    incomingMessageEvent(btMes);
                    Console.WriteLine("Received: " + btMes.name + " -> " + btMes.getValueAsNumber());
                }
            }
        }
    }, _tokenSource2.Token, TaskCreationOptions.LongRunning, TaskScheduler.Current);
}
于 2017-08-02T12:34:05.850 回答