使用 Timer 和 Thread、股票应用程序更新 Winforms 标签

Question

之前可能有人问过它的要点，但我完全迷路了，所以我正在寻找一些个人指导。一直在尝试使用 WinForms 和 Yahoo API 为有趣的人制作股票跟踪器应用程序。尝试获取它，以便您可以输入跟踪器符号，它将创建一个新的标签，该标签将不时地自我更新。但是，它不断给我有关“跨线程操作无效”的错误消息。我试图做一些谷歌搜索，但是，是的，完全迷路了。大部分代码都写到这里了，希望大家能看懂。

using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using YahooFinanceApi;

namespace stockpoging4
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            System.Globalization.CultureInfo.DefaultThreadCurrentUICulture = System.Globalization.CultureInfo.GetCultureInfo("en-US");
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            using (Prompt prompt = new Prompt("Enter the ticker symbol", "Add ticker"))
            {
                string result = prompt.Result;
                result = result.ToUpper();
                if (!string.IsNullOrEmpty(result))
                {
                    do_Things(result);
                }
            }
        }
        public async Task<string> getStockPrices(string symbol)
        {
            try
            {
                var securities = await Yahoo.Symbols(symbol).Fields(Field.RegularMarketPrice).QueryAsync();
                var aapl = securities[symbol];
                var price = aapl[Field.RegularMarketPrice];
                return symbol + " $" + price;

            }
            catch
            {
                return "404";
            }
        }


        public async void do_Things(string result)
        {
            string price;
            Label label = null;

            if (label == null)
            {
                price = await getStockPrices(result);
                label = new Label() { Name = result, Text = result + " $" + price };
                flowLayoutPanel2.Controls.Add(label);
            }
            else
            {
                Thread testThread = new Thread(async delegate ()
                {
                    uiLockingTask();
                    price = await getStockPrices(result);
                    label.Text = result + " $" + price;
                    label.Update();
                });
            }
            System.Timers.Timer timer = new System.Timers.Timer(10000);
            timer.Start();
            timer.Elapsed += do_Things(results);
        }

        private void uiLockingTask() {
            Thread.Sleep(5000);
        }
    }
}

Answer 1

让我指出你的实现中的几件事。

1. 您订阅 timer.Elapsed after timer.Start 可能在短时间间隔的情况下无效
2. 在后台调用事件处理程序，这就是为什么您不断收到“跨线程操作无效”的原因。 UI 组件应该从后台线程正确调度，例如，通过调用 flowLayoutPanel2.BeginInvoke(new Action(() => flowLayoutPanel2.Controls.Add(label)));和 label.BeginInvoke(new Action(label.Update))。此更改已经可以解决您的异常。
3. 尽管我会以不同的方式实现此功能，但在这里我发布了一些稍作改动的代码，通过一些调整可以完全满足您的需求。

    public partial class Form1 : Form 
    {
        Task _runningTask;
        CancellationTokenSource _cancellationToken;
    
        public Form1()
        {
            System.Globalization.CultureInfo.DefaultThreadCurrentUICulture = System.Globalization.CultureInfo.GetCultureInfo("en-US");
            InitializeComponent();
        }
    
        private void button1_Click(object sender, EventArgs e)
        {
            using (Prompt prompt = new Prompt("Enter the ticker symbol", "Add ticker"))
            {
                string result = prompt.Result;
                result = result.ToUpper();
                if (!string.IsNullOrEmpty(result))
                {
                    do_Things(result);
                    _cancellationToken = new CancellationTokenSource();
                    _runningTask = StartTimer(() => do_Things(result), _cancellationToken);
                }
            }
        }
    
        private void onCancelClick()
        {
            _cancellationToken.Cancel();
        }
    
    
        public async Task<string> getStockPrices(string symbol)
        {
            try
            {
                var securities = await Yahoo.Symbols(symbol).Fields(Field.RegularMarketPrice).QueryAsync();
                var aapl = securities[symbol];
                var price = aapl[Field.RegularMarketPrice];
                return symbol + " $" + price;
    
            }
            catch
            {
                return "404";
            }
        }
    
        private async Task StartTimer(Action action, CancellationTokenSource cancellationTokenSource)
        {
            try
            {
                while (!cancellationTokenSource.IsCancellationRequested)
                {
                    await Task.Delay(1000, cancellationTokenSource.Token);
                    action();
                }
            }
            catch (OperationCanceledException) { }
        }
    
    
        public async void do_Things(string result)
        {
            var price = await getStockPrices(result);
            var label = new Label() { Name = result, Text = result + " $" + price };
            flowLayoutPanel2.BeginInvoke(new Action(() => flowLayoutPanel2.Controls.Add(label)));
        }
    }

Answer 2

如今，一种更简单的方法是使用异步。

这是一个每个间隔触发Action 的类：

public class UITimer : IDisposable
{
    private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();

    // use a private function which returns a task
    private async Task Innerloop(TimeSpan interval, Action<UITimer> action)
    {
        try
        {
            while (!_cancellationTokenSource.IsCancellationRequested)
            {
                await Task.Delay(interval, _cancellationTokenSource.Token);
                action(this);
            }
        }
        catch (OperationCanceledException) { }
    }

    // the constructor calls the private StartTimer, (the first part will run synchroniously, until the away delay) 
    public UITimer(TimeSpan interval, Action<UITimer> action) =>
        _ = Innerloop(interval, action);

    // make sure the while loop will stop.
    public void Dispose() =>
        _cancellationTokenSource?.Cancel();
}

如果您使用 dotnet 3.0 或更高版本，则可以使用 IAsyncDisposable。有了这个，您就可以等待 DisposeAsync 方法，因此您可以等待 _timerTask 完成。

我创建了一个新表单，并以此作为代码：

public partial class Form1 : Form
{
    private readonly UITimer _uiTimer;
    private int _counter;

    public Form1()
    {
        InitializeComponent();

        // setup the time and pass the callback action
        _uiTimer = new UITimer(TimeSpan.FromSeconds(1), Update);
    }

    // the orgin timer is passed as parameter.
    private void Update(UITimer timer)
    {
        // do your thing on the UI thread.
        _counter++;
        label1.Text= _counter.ToString();
    }

    private void Form1_FormClosed(object sender, FormClosedEventArgs e)
    {
        // make sure the time (whileloop) is stopped.
        _uiTimer.Dispose();
    }
}

优点是，回调在 UI 线程上运行，但不会阻塞它。 await Task.Delay(..) 在后台使用 Timer，但在 UI 线程上发布其余的方法/状态机（因为 UI 线程有 SynchronizaionContext）

简单但成功;-)