如何实现异步工作流程？

发布于 2024-10-31 11:35:21 字数 1483 浏览 3 评论 0原文

        WorkflowInvoker invoker = new WorkflowInvoker(new Workflow1());

        for (int i = 0; i < 10; i++)
        {
            //invoker.InvokeAsync(myOrders);
            IAsyncResult result = invoker.BeginInvoke(myOrders,new AsyncCallback(WorkflowCompletedCallback),order);
        }

我使用上面的代码来实现异步工作流程。我希望运行此工作流程 10 次，并且我有类似的线程池，因此 10 个工作流程线程可以同时运行。第二个不需要等待第一个完成其工作。我的工作流程非常简单，它将进行一些计算并在屏幕上打印几个句子。运行上面的代码后，我发现似乎10个工作流程被一一调用，而不是我希望同时运行的。异步工作流程的正确方法是什么？谢谢你！

更新：在其他人的一些反馈之后，我还尝试使用工作流应用程序异步执行此操作：

        WorkflowApplication wfApp = new WorkflowApplication(new Workflow1(), myOrders);
        for (int i = 0; i < 10; i++)
        {
            wfApp.Run();
        }

        /* Read the end time. */
        DateTime stopTime = DateTime.Now;
        Console.WriteLine(stopTime);
        // Duration
        TimeSpan duration = stopTime - startTime;
        Console.WriteLine("hours:" + duration.TotalHours);
        Console.WriteLine("minutes:" + duration.TotalMinutes);
        Console.WriteLine("seconds:" + duration.TotalSeconds);
        Console.WriteLine("milliseconds:" + duration.TotalMilliseconds);

这是运行结果： 2011 年 4 月 8 日上午 9:57:49 2011 年 4 月 8 日上午 9:57:50 小时：6.27777777777778E-05 分钟：0.00376666666666667 秒：0.226 毫秒：226 处理订单客户：10 |运送：次日 |总价：250 |运费：10 产品编号：1 |数量：5 |价格：50 产品编号：2 |数量：10 |价格：200

看起来它是异步的，但实际上只有一个线程正在运行我的工作流程（不是主应用程序线程）。但从输出中我只看到一个线程正在运行我的工作流程。如何让 10 个线程同时运行工作流程？谢谢你！

原文

        WorkflowInvoker invoker = new WorkflowInvoker(new Workflow1());

        for (int i = 0; i < 10; i++)
        {
            //invoker.InvokeAsync(myOrders);
            IAsyncResult result = invoker.BeginInvoke(myOrders,new AsyncCallback(WorkflowCompletedCallback),order);
        }

I use the above code to implement asynchronized workflow. I hope to run this workflow for 10 times and I have something similar with thread pool so the 10 workflow thread could run at the same time. The second doesn't need to wait for the first one finished its job. My workflow is very simple it will do some calculation and print several sentences on screen. After I run the above code, I find it seems the 10 workflows are invoked one by one not as what I hoped to run at the same time. What is the correct way to asynchronize workflow? Thank you!

Update: After some feed back from others, I also try use workflowapplication to do this asynchronizely:

        WorkflowApplication wfApp = new WorkflowApplication(new Workflow1(), myOrders);
        for (int i = 0; i < 10; i++)
        {
            wfApp.Run();
        }

        /* Read the end time. */
        DateTime stopTime = DateTime.Now;
        Console.WriteLine(stopTime);
        // Duration
        TimeSpan duration = stopTime - startTime;
        Console.WriteLine("hours:" + duration.TotalHours);
        Console.WriteLine("minutes:" + duration.TotalMinutes);
        Console.WriteLine("seconds:" + duration.TotalSeconds);
        Console.WriteLine("milliseconds:" + duration.TotalMilliseconds);

It seems it is asynchronized but only one thread is actually running my workflow (not the main application thread). But from the output I only see one thread is running my workflow. How could I let 10 threads run the workflow at the same time? Thank you!

分享到QQ

分享到微博