Azure中的多线程

问题描述

我想通过通过Azure函数运行Windows服务来将其转变为天蓝色。

windows服务使用Parallel.ForEach循环运行多线程，并且只是为了测试多线程是否在Azure中完美运行，我编写了以下代码：

天蓝色功能：

[FunctionName("Function1")]
public static void Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,TraceWriter log)
{
    try
    {
        Process process = new Process();

        process.StartInfo.FileName = @"D:\home\site\wwwroot\Dependency\MasterVB\MasterVB.exe";
        process.StartInfo.Arguments = "";
        process.StartInfo.UseShellExecute = false;
        process.StartInfo.RedirectStandardOutput = true;
        process.StartInfo.RedirectStandardError = true;

        log.Info("Before Calling Start ");
        process.Start();
        log.Info("After Calling Start ");

        string output = process.StandardOutput.ReadToEnd();
        string err = process.StandardError.ReadToEnd();
        process.WaitForExit();
    }
    catch
    {
      //left out for brevity
    }
}

MasterVB.exe：

Imports System.Collections.Concurrent
Imports Microsoft.WindowsAzure.Storage
Imports Microsoft.WindowsAzure.Storage.Blob
    
Module Module1
    
    Public connectionString As String = "DefaultEndpointsProtocol=https;AccountName=r53eripcjroswtest;AccountKey=cktlWe/byeSOis94OOA0YFlHPRrAfmORuy9xRGScTrxwuliY4KmZfAif8aF4cgng2mnDLvJWIvxl0xEPMU6DKw==;"
    Public storageAccount As CloudStorageAccount = CloudStorageAccount.Parse(connectionString)
    Public serviceClient As CloudBlobClient = storageAccount.CreateCloudBlobClient()
    Public container As CloudBlobContainer = serviceClient.GetContainerReference("igb-test")
    Public blob As CloudAppendBlob = container.GetAppendBlobReference("DocumentMaster.txt")
    
    Sub Main()
    
        If Not blob.Exists Then
            blob.CreateOrReplace()
        End If
    
        Dim dealist As New List(Of String)
    
        dealist.Add("First")
        dealist.Add("Second")
        dealist.Add("Third")
        dealist.Add("Fourth")
        dealist.Add("Fifth")
        dealist.Add("Sixth")
        dealist.Add("Seventh")
        dealist.Add("Eighth")
        dealist.Add("Nine")
        dealist.Add("Tenth")
        Dim exceptions As New ConcurrentQueue(Of Exception)
        Dim opts As New ParallelOptions
        opts.MaxDegreeOfParallelism = -1
        Parallel.ForEach(dealist,opts,Sub(deal)
                                            If Len(deal) > 0 Then
                                                Try
                                                    Dim p As New Process()
                                                    p.StartInfo.FileName = "D:\home\site\wwwroot\Dependency\MasterVB\ChildVB\ChildVB.exe"
                                                    p.StartInfo.Arguments = deal
                                                    p.StartInfo.UseShellExecute = False
                                                    p.StartInfo.CreateNoWindow = True
                                                    p.Start()
                                                    p.WaitForExit()
                                                Catch ex As Exception
                                                    exceptions.Enqueue(ex)
                                                End Try
                                            End If
                                        End Sub)
    
        If exceptions.Count > 0 Then
            For Each ex In exceptions
                'Console.WriteLine(ex.Message)
                blob.AppendText(ex.Message + Environment.NewLine)
            Next
        End If
    
    End Sub
    
End Module

ChildVB.exe

Imports Microsoft.WindowsAzure.Storage
Imports Microsoft.WindowsAzure.Storage.Blob
Module Module1
    Public keycode As String = ""
    Public dealPass As String = ""
    Public runType As String = ""
    
    Public connectionString As String = "DefaultEndpointsProtocol=https;AccountName=r53eripcjroswtest;AccountKey=cktlWe/byeSOis94OOA0YFlHPRrAfmORuy9xRGScTrxwuliY4KmZfAif8aF4cgng2mnDLvJWIvxl0xEPMU6DKw==;"
    Public storageAccount As CloudStorageAccount = CloudStorageAccount.Parse(connectionString)
    Public serviceClient As CloudBlobClient = storageAccount.CreateCloudBlobClient()
    Public container As CloudBlobContainer = serviceClient.GetContainerReference("igb-test")
    Public blob As CloudAppendBlob = container.GetAppendBlobReference("DocumentChild.txt")
    
    Sub Main()
        Dim clArgs() As String = Environment.GetCommandLineArgs()
    
        If Not blob.Exists Then
            blob.CreateOrReplace()
        End If
            
        If clArgs.Count = 2 Then
    
            Dim args As String = clArgs(1)
            blob.AppendText(args + "----" + DateTime.Now.ToString("MM/dd/yyyy HH:mm:ss") + Environment.NewLine)                
    
        End If
    End Sub
    
End Module

在DocumentChild.txt中，我得到以下输出：

First----08/12/2020 15:15:03
Sixth----08/12/2020 15:15:04
Third----08/12/2020 15:15:05
Seventh----08/12/2020 15:15:06
Fourth----08/12/2020 15:15:07
Nine----08/12/2020 15:15:09
Tenth----08/12/2020 15:15:10
Fifth----08/12/2020 15:15:10

First----08/12/2020 15:20:17
Sixth----08/12/2020 15:20:17
Second----08/12/2020 15:20:18
Seventh----08/12/2020 15:20:19
Fifth----08/12/2020 15:20:21
Eighth----08/12/2020 15:20:21
Nine----08/12/2020 15:20:23
Tenth----08/12/2020 15:20:23
Fourth----08/12/2020 15:20:24

First----08/12/2020 15:25:02
Sixth----08/12/2020 15:25:03
Second----08/12/2020 15:25:04
Seventh----08/12/2020 15:25:04
Third----08/12/2020 15:25:05
Fifth----08/12/2020 15:25:06
Eighth----08/12/2020 15:25:07
Fourth----08/12/2020 15:25:07
Nine----08/12/2020 15:25:09
Tenth----08/12/2020 15:25:09

First----08/12/2020 15:30:01
Sixth----08/12/2020 15:30:01
Second----08/12/2020 15:30:03
Third----08/12/2020 15:30:03
Seventh----08/12/2020 15:30:04
Fifth----08/12/2020 15:30:05
Nine----08/12/2020 15:30:06
Fourth----08/12/2020 15:30:06
Eighth----08/12/2020 15:30:07
Tenth----08/12/2020 15:30:08

First----08/12/2020 15:35:02
Second----08/12/2020 15:35:04
Third----08/12/2020 15:35:04
Fifth----08/12/2020 15:35:06
Seventh----08/12/2020 15:35:06
Fourth----08/12/2020 15:35:07
Nine----08/12/2020 15:35:08
Eighth----08/12/2020 15:35:08
Tenth----08/12/2020 15:35:09

以上各行显示了在5分钟内经过5次不同时间运行的每个不同的Azure功能的输出。第一个和第二个实例在15:15和15:20的输出不会输出所有十个字符串，但是在第三和第四个实例中会输出，但是在第五个实例中不会输出所有字符串。在实际的代码中，MasterVB中提到的交易清单将包含4,000多个以相同方式处理的字符串，即使用多线程的主调用子项。

我的问题是：

为什么在这种情况下多线程不一致，并且每次都打印所有十个字符串？我担心的是，如果它仅与10个字符串不一致，它是否能够使用
处理4000个字符串比仅打印到ChildVB模块中的文本文件还要更多的操作？
是否有其他好方法可以将涉及多线程的Windows服务转变为天蓝色。
是否有可能与部署计划有关。

注意：

1。我正在使用消费计划进行部署，但是没有遇到任何超时等问题作为标准计划（10分钟）

我已经运行了几次不同的时间，但是每次天蓝色时，这种矛盾仍然存在函数运行。
没有任何编译错误或运行时错误。

解决方法

虽然可能无法确定为什么没有详细的日志无法完成所有运行，但我可以为您的方案（以及许多类似的方案）提出解决方案。

首先，可以将需要处理的每个字符串的消息插入队列（service bus或storage queue）中，而不是字符串列表。您甚至可以使用HTTP Trigger函数，使用适当的输出绑定（service bus或storage queue）将消息插入队列。

然后，根据您选择的队列服务，您将拥有一个由其适当的触发器（service bus或storage queue）触发的功能。如果您正在consumption或premium计划上运行此功能，则该功能将根据消息数进行扩展。

如果需要按顺序处理消息的子集，则必须使用服务总线的message sessions。服务总线触发器有一个configuration setting，您必须将其设置为接受消息会话。

azure azure-function-app azure-functions multithreading parallel.foreach

Azure中的多线程

问题描述

解决方法

相关问答