下面的代码不能“实时”工作。目的是,当单击按钮时,验证后台线程上的一组数据。在验证所有数据之前,我不能允许真正的“提交”,但我确实希望文本框实时更新。
相反,文本框会一次更新为奇数。
我想正在发生的事情是 task.Wait 阻塞了 observable,因为我在主线程上观察,但我看不到解决这个问题的方法,因为我需要在主线程上更新。
(显然这只是一个概念证明)
有点相关的注释 - 这段代码是否保证线程安全?谢谢。
private Subject<int> _subject;
public Form1()
{
InitializeComponent();
}
private int sleep = 2000;
private int i = 0;
private void LongRunningValidation(int num)
{
if (num % 2 == 0) return;
Thread.Sleep(sleep * (i++));
_subject.OnNext(num);
}
private ConcurrentBag<int> _bag;
private void simpleButton1_Click(object sender, EventArgs e)
{
_subject = new Subject<int>();
_subject.SubscribeOn(Scheduler.TaskPool).ObserveOn(SynchronizationContext.Current).Synchronize().Subscribe(UpdateTextBox);
_bag = new ConcurrentBag<int>() { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
if(Validate())
{
//submit
}
}
private bool Validate()
{
var task = Task.Factory.StartNew(StartValidationAsync);
task.Wait();
return true;
}
private void StartValidationAsync()
{
Parallel.ForEach(_bag, LongRunningValidation);
}
private void UpdateTextBox(int i)
{
textEdit1.Text = textEdit1.Text + "," + i;
}
}