无法启动Azure Worker角色，异常代码0xe043352&；0xC0000035

在模拟器中本地运行时，web工作程序工作正常。然而，每当我更新在Azure VM上运行的web工作程序时，我都会在事件查看器中获得以下异常，并且角色不会启动：

应用程序：WaWorkerHost.exe
框架版本：v4.0.30319
描述：由于出现未处理的异常，进程已终止
异常信息：System.AggregateException
堆栈：位于System.Threading.Tasks.Task.Wait（Int32，System.Threading.CancellationToken）位于System.Threading.Tasks.Task.Wet（）
在Foo.PushProcess.WorkerRole.Run（）
位于Microsoft.WindowsAzure.ServiceRuntime.RoleEnvironment.StartRoleInternal（）位于Microsoft.WindowsAzure.ServiceRuntime.Elementation.Loader.RoleRuntimeBridge.b_2（）位于System.Threading.ExecutionContext.RunInternal（System.Threading.ExecutionContext、System.Threading.ContextCallback、System.Object、Boolean）
位于System.Threading.ExecutionContext.Run（System.Threading.ExecutionContext、System.Threading.ContextCallback、System.Object、Boolean）
位于System.Threading.ExecutionContext.Run（System.Threading.ExecutionContext、System.Threading.ContextCallback、System.Object）
位于System.Threading.ThreadHelper.ThreadStart（）

内部异常：任务已取消。

出现故障的应用程序名称：WaWorkerHost.exe，版本：2.6.1198.712，时间戳：0x54eba731
故障模块名称：KERNELBASE.dll，版本：6.3.9600.17415，时间戳：0x54505737
异常代码：0xe0434352
故障偏移量：0x0000000000008b9c
出现故障的进程id:0xfb8
出现故障的应用程序启动时间：0x01d11e3128981a5d
出现故障的应用程序路径：E:''base''x64''WaWorkerHost.exe
出现故障的模块路径：D:''Windows''system32''KERNELBASE.dll
报告Id:30631c5c-8a25-11e5-8066-0000d3a22f3ec
出现故障的程序包全名：
出现故障的程序包相关应用程序ID:

会话"MA_ETWSESSION_WAD_415df88f8a0447178dbd4c18f1349f0e_Foo.PushProcess_Foo.PushProcess_IN_0"未能启动，出现以下错误：0xC0000035

这是相关代码：

public override void Run()
{
    Trace.TraceInformation("Foo.PushProcess is running");
    try
    {
        RunAsync(_cancellationTokenSource.Token).Wait(); // This is where the exceptions point to
    }
    catch (Exception ex)
    {
        Trace.TraceError("[WORKER] Run error: " + ex);
    }
    finally
    {
        _runCompleteEvent.Set();
    }
}
public override bool OnStart()
{
    // Set the maximum number of concurrent connections
    ServicePointManager.DefaultConnectionLimit = 12;
    // For information on handling configuration changes
    // see the MSDN topic at http://go.microsoft.com/fwlink/?LinkId=166357.
    bool result = base.OnStart();
    _storageAccount = CloudStorageAccount.Parse(RoleEnvironment.GetConfigurationSettingValue("StorageConnectionString"));
    var queueClient = _storageAccount.CreateCloudQueueClient();
    _pushQueue = queueClient.GetQueueReference("pushes");
    _pushQueue.CreateIfNotExists();
    CreatePushBroker();
    Trace.TraceInformation("Foo.PushProcess has been started");
    return result;
}
private async Task RunAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        Trace.TraceInformation("Working");
        CloudQueueMessage message = null;
        try
        {
            message = _pushQueue.GetMessage();
            if (message != null)
            {
                ProcessItem(message);
            }
        }
        catch (Exception ex)
        {
            if (message != null && message.DequeueCount > 5)
                _pushQueue.DeleteMessage(message);
            Trace.TraceError("[WORKER] Retrieval Failure: " + ex);
        }
        await Task.Delay(1000, cancellationToken);
    }
}

请注意，有些代码被省略了，但这些代码都是在初始化后运行的，理论上这个异常不会到达。

我完全不知道是什么原因导致了这个问题。任何帮助都将不胜感激——即使只是为了帮助我获得一个有用的例外。

更新

我现在已经把我的代码简化到下面——这是一个网络工作者可能做到的最简单的事情——我仍然会遇到异常。我认为，要么是旧的工作进程正在被缓存，要么是部署过程中出现了问题。

public override void Run()
{
    Trace.TraceInformation("Foo.PushProcess is running");
    try
    {
        RunAsync(_cancellationTokenSource.Token).Wait(); // This is where the exceptions point to
    }
    catch (Exception ex)
    {
        Trace.TraceError("[WORKER] Run error: " + ex);
    }
    finally
    {
        _runCompleteEvent.Set();
    }
}
public override bool OnStart()
{
    // Set the maximum number of concurrent connections
    ServicePointManager.DefaultConnectionLimit = 12;
    // For information on handling configuration changes
    // see the MSDN topic at http://go.microsoft.com/fwlink/?LinkId=166357.
    bool result = base.OnStart();
    return result;
}
private async Task RunAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        Trace.TraceInformation("Working");
        // code removed for testing - no work is being done.
        await Task.Delay(1000, cancellationToken);
    }
}

public class WorkerRole : RoleEntryPoint
{
    private readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
    private readonly ManualResetEvent runCompleteEvent = new ManualResetEvent(false);
    private CloudQueue _pushQueue;
    private CloudStorageAccount _storageAccount;
    public override void Run()
    {
        Trace.TraceInformation("WorkerRole1 is running");
        try
        {
            this.RunAsync(this.cancellationTokenSource.Token).Wait();
        }
        catch (Exception ex)
        {
            Trace.TraceError("[WORKER] Run error: " + ex);
        }
        finally
        {
            this.runCompleteEvent.Set();
        }
    }
    public override bool OnStart()
    {
        // Set the maximum number of concurrent connections
        ServicePointManager.DefaultConnectionLimit = 12;
        // For information on handling configuration changes
        // see the MSDN topic at http://go.microsoft.com/fwlink/?LinkId=166357.
        bool result = base.OnStart();
        _storageAccount = CloudStorageAccount.Parse(RoleEnvironment.GetConfigurationSettingValue("StorageConnectionString"));
        var queueClient = _storageAccount.CreateCloudQueueClient();
        _pushQueue = queueClient.GetQueueReference("pushes");
        _pushQueue.CreateIfNotExists();
        CreatePushBroker();
        Trace.TraceInformation("Foo.PushProcess has been started");
        return result;
    }
    private void CreatePushBroker()
    {
        return;
    }
    public override void OnStop()
    {
        Trace.TraceInformation("WorkerRole1 is stopping");
        this.cancellationTokenSource.Cancel();
        this.runCompleteEvent.WaitOne();
        base.OnStop();
        Trace.TraceInformation("WorkerRole1 has stopped");
    }
    private async Task RunAsync(CancellationToken cancellationToken)
    {
        // TODO: Replace the following with your own logic.
        while (!cancellationToken.IsCancellationRequested)
        {
            Trace.TraceInformation("Working");
            CloudQueueMessage message = null;
            try
            {
                message = _pushQueue.GetMessage();
                if (message != null)
                {
                    ProcessItem(message);
                }
            }
            catch (Exception ex)
            {
                if (message != null && message.DequeueCount > 5)
                    _pushQueue.DeleteMessage(message);
                Trace.TraceError("[WORKER] Retrieval Failure: " + ex);
            }
            await Task.Delay(1000, cancellationToken);
        }
    }
    private void ProcessItem(CloudQueueMessage message)
    {
        return;
    }
}