c# - 与 Iron Python 异步等待

Question

现在我使用并行方法来检查 200 状态代码的 url，但这是一种缓慢的方法。现在我正在尝试将我的代码移动到 await/async 方法，但它不起作用

        private async void button1_Click(object sender, EventArgs e)
        {
            DateTime start = DateTime.Now;

            var timerPostingSpeed = new Timer(state =>
            {
                TimeSpan elapsed = DateTime.Now - start;
                string postingSpeed = string.Format("{0:0}",
                                                   finishedUrls * 60 / (int)elapsed.TotalSeconds);
                UpdatingLabel(label1, postingSpeed);
            }, null, 5000, 10000);


            IEnumerable<string> urls = File.ReadLines("urls.txt");

            var engine = Python.CreateEngine();

            var scriptSource =
                   engine.CreateScriptSourceFromString(@"
                        if Open(__URL).Result:
                            print 1
                        ");

            await urls.ForEachAsync(20, async line =>
            {
                try
                {

                    var adderEngine = new SpeedEngine();
                  //  int zz = await adderEngine.Open(line);
                   // return;
                        ScriptScope scope = engine.CreateScope();

                        scope.SetVariable("__URL", line);

                        scope.SetVariable("Open",
                            new Func<string, Task<int>>(adderEngine.Open));
                    try
                    {
                        await scriptSource.Execute(scope);
                    }
                    catch (UnboundNameException une)
                    {
                        MessageBox.Show(une.Message,
                            msg.
                                MySeoBoxForm_startPostingToolStripButton_Click_Unbound_Name_Error,
                            MessageBoxButtons.OK, MessageBoxIcon.Error);
                    }
                    catch (SyntaxErrorException see)
                    {
                        MessageBox.Show(
                            string.Format("{0}\nLine: {1}\nCode: {2}",
                                see.Message,
                                see.Line, see.GetCodeLine()),
                            msg.
                                MySeoBoxForm_startPostingToolStripButton_Click_Syntax_Error,
                            MessageBoxButtons.OK, MessageBoxIcon.Error);
                    }
                    catch (MissingMemberException mme)
                    {
                        MessageBox.Show(mme.Message, "Missing Member",
                            MessageBoxButtons.OK, MessageBoxIcon.Error);
                    }
                    catch (ArgumentTypeException ate)
                    {
                        MessageBox.Show(string.Format("{0}", ate.Message),
                            msg.
                                MySeoBoxForm_startPostingToolStripButton_Click_Syntax_Error,
                            MessageBoxButtons.OK, MessageBoxIcon.Error);
                    }
                    catch (SystemExitException)
                    {

                    }
                    catch (Exception exc)
                {
                     MessageBox.Show(string.Format("{0}", exc.Message),
                       msg.
                           MySeoBoxForm_startPostingToolStripButton_Click_Syntax_Error,
                       MessageBoxButtons.OK, MessageBoxIcon.Error);
                }
                    finally
                    {

                     MessageBox.Show(string.Format("{0}","OK"),
                       msg.
                           MySeoBoxForm_startPostingToolStripButton_Click_Syntax_Error,
                       MessageBoxButtons.OK, MessageBoxIcon.Error);

                    }

                }
                catch (Exception exc)
                {
                     MessageBox.Show(string.Format("{0}", exc.Message),
                       msg.
                           MySeoBoxForm_startPostingToolStripButton_Click_Syntax_Error,
                       MessageBoxButtons.OK, MessageBoxIcon.Error);
                }

                finally
                {
                    Interlocked.Increment(ref finishedUrls);
                    numericUpDown1.Invoke(new MethodInvoker(delegate
                    {
                        numericUpDown1.Value++;
                    }));
                }

            });
            timerPostingSpeed.Dispose();
        }

    }

   public async Task<int> Open(string siteUrl)
        {
                Uri newUri;
                if (!Uri.TryCreate(siteUrl, UriKind.Absolute, out newUri)) return 0;
                _uri = _openUri = newUri;
                _req = new HttpRequestMessage(HttpMethod.Get, _uri);

                _response = await _httpClient.SendAsync(_req);

                if (_response == null || !_response.IsSuccessStatusCode)
                {
                  return 0;
                }


                return 1;
        }

我需要使用 Iron Python - 没有它(当我取消注释 await adderEngine.Open(line); return; 时)一切正常。但是使用 Iron Python 我的应用程序停止在 *_response = await _httpClient.SendAsync(_req);* 没有错误。当我更换时我也注意到了

await urls.ForEachAsync(20, async line =>

与:

await urls.ForEachAsync(1, async line =>

它在工作

ForEachAsync:http://blogs.msdn.com/b/pfxteam/archive/2012/03/05/10278165.aspx

有什么帮助吗？

Answer 1

如果您的 Python 代码正在调用 Task.Result，并且您在 UI 线程上(似乎是这种情况)，you can cause a deadlock (我在我的博客上对此进行了全面解释)。简而言之，async 方法 (Open) 试图在 UI 线程上恢复执行，但是 UI 线程被调用 Result 阻塞了。

据我所知，Python 没有async/await 支持，但是你应该可以使用ContinueWith (meh) 或者写一些类似的东西Task 和 Twisted 的 Deferred 之间的桥梁(更酷)。