我在多線程和事件中遇到了一些問題。多線程和事件
我有以下函數執行線程數:
private void GetProjectInformation(object obj)
{
//Casten
//string projectName = (string)obj;
FilterOptions filter = (FilterOptions)obj;
ProjectConnectionManager connectionManager = new ProjectConnectionManager();
connectionManager.GetProjectInfo(filter);
connectionManager.InfoReceived += delegate(object sender, ProjectInfoEventArgs e)
{
//Geupdate resultaat in de collection vervangen
int index = 0;
bool found = false;
m_dispatcher.Invoke(DispatcherPriority.Normal, (Action)(() =>
{
foreach (ProjectInfo projectInfo in m_allProjects)
{
if (String.Equals(projectInfo.ProjectName, e.ProjectInfo.ProjectName))
{
found = true;
ProjectInfo result = e.ProjectInfo;
m_allProjects[index] = e.ProjectInfo;
break;
}
index++;
}
//Niet gevonden
if (!found)
{
m_allProjects.Add(e.ProjectInfo);
}
}));
};
}
它被稱爲是這樣的:
foreach (FilterOptions opt in m_projectsToShow)
{
Thread thread =
new Thread(new ParameterizedThreadStart(GetProjectInformation));
thread.Start(opt);
}
我面對(我認爲)的問題,是
後connectionManager.GetProjectInfo(filter);
我的線程取消。我得到一個AggregateException,它告訴我一個任務已經關閉,所以我想這必須是問題。我想達到的是以下幾點。我的功能,所以當前線程,有阻塞,直到該事件已經被解僱:
connectionManager.InfoReceived += ...
是否有任何解決這個?你能給我一些代碼嗎?
編輯:
這是GetProjectInfo方法:
public void GetProjectInfo(FilterOptions filter)
{
ProjectInfo result = new ProjectInfo();
try
{
var task = m_httpClient.PostAsync(string.Format("api/project"), new ObjectContent<FilterOptions>(filter, XmlMediaTypeFormatter.DefaultMediaType));
task.ContinueWith(r =>
{
try
{
r.Wait();
if (r.Result.IsSuccessStatusCode)
{
Console.WriteLine("Project " + filter.ProjectName + " was succesfull...");
r.Result.Content.ReadAsAsync<ProjectInfo>().ContinueWith(l =>
{
result = l.Result;
OnProjectInfoReceived(new ProjectInfoEventArgs(result));
});
}
else
{
Console.WriteLine("Project " + filter.ProjectName + " failed!");
}
}
catch (AggregateException ex)
{
Console.WriteLine(ex.ToString());
}
}).Wait(m_httpClient.Timeout);
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}
我也得到了AggregateException在那裏。
這是例外:
System.AggregateException was caught
Message=One or more errors occurred.
Source=mscorlib
StackTrace:
at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)
at System.Threading.Tasks.Task`1.get_Result()
at Dashboard.Utils.ProjectConnectionManager.<>c__DisplayClass8.<GetProjectInfo>b__5(Task`1 r) in C:\Users\xxx\Documents\My Own Documents\xxx\ProjectConnectionManager.cs:line 79
InnerException: System.Threading.Tasks.TaskCanceledException
Message=A task was canceled.
InnerException:
'm_allProjects'最好是線程安全的集合。 – 2012-04-10 10:19:41
'GetProjectInfo()'是否以某種方式啓動另一個線程?否則,你應該先把事件連接起來。 – 2012-04-10 10:23:38
謝謝Henk,我也應該看看。但我首先想解決我的主要問題:) – 2012-04-10 10:23:44