如何解决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，您必须将其设置为接受消息会话。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。