早讀課老師安排學(xué)生們讀課文,突然老師想抽根煙,就跟班長說讀完跑去告訴他。
public class ReadEventArgs : EventArgs
{
public object State { get; set; }
public int Length { get; set; }
public List<ArraySegment<byte>> Content { get; set; }
public event EventHandler<ReadEventArgs> Finished;
}
public class Student
{
public void ReadAsync(ReadEventArgs eventArgs)
{
// 這個(gè)方法會(huì)很快返回。但是,在學(xué)生讀書結(jié)束的時(shí)候,F(xiàn)inished事件會(huì)自動(dòng)觸發(fā)。
}
}
public class Monitor
{
private Student _student = new Student();
public Task<bool> WatchStudentRead()
{
}
}
class Teacher
{
Monitor _monitor = new Monitor();
public async void Smoke()
{
var task = _monitor.WatchStudentRead();
// smoking
await task;
// go back to classroom
}
}
請問這里班長怎么做,才能實(shí)現(xiàn)異步任務(wù)? Student.ReadAsync實(shí)際上不是異步方法,不可以await,也不代表完成,這意味著 WatchStudentRead 內(nèi)部創(chuàng)建task也是行不通的。
好在TPL神通廣大,我們可以通過TaskCompletionSource來實(shí)現(xiàn)。 TaskCompletionSource可以只管理任務(wù),但不運(yùn)行實(shí)際任務(wù)。
Monitor.cs
public Task<bool> WatchStudentRead()
{
var tasksource = new TaskCompletionSource<bool>();
var e = new ReadEventArgs();
e.State = tasksource;
e.Finished += OnReadFinished;
_student.ReadAsync(e);
return tasksource.Task;
}
private void OnReadFinished(object sender, ReadEventArgs e)
{
var tasksource = e.State as TaskCompletionSource<bool>;
if (tasksource != null)
{
tasksource.SetResult(e.Length > 0);
}
}
怎么樣,是不是很有趣,返回的task并沒有做實(shí)際工作,只是在等待結(jié)果。
這種場景挺常見,值得注意。