C#多线程(14)：任务基础②代码有点多，不易观察，请复制到程序中运行。
class Program
{
static void Main()
{
// 正常任务
Task task1 = new Task(() =>
{
});
task1.Start();
Thread.Sleep(TimeSpan.FromSeconds(1));
GetResult(task1.IsCanceled, task1.IsFaulted);
Console.WriteLine("任务是否完成：" + task1.IsCompleted);
Console.WriteLine("-------------------");
// 异常任务
Task task2 = new Task(() =>
{
throw new Exception();
});
task2.Start();
Thread.Sleep(TimeSpan.FromSeconds(1));
GetResult(task2.IsCanceled, task2.IsFaulted);
Console.WriteLine("任务是否完成：" + task2.IsCompleted);
Console.WriteLine("-------------------");
Thread.Sleep(TimeSpan.FromSeconds(1));
CancellationTokenSource cts = new CancellationTokenSource();
// 取消任务
Task task3 = new Task(() =>
{
Thread.Sleep(TimeSpan.FromSeconds(3));
}, cts.Token);
task3.Start();
cts.Cancel();
Thread.Sleep(TimeSpan.FromSeconds(1));
GetResult(task3.IsCanceled, task3.IsFaulted);
Console.WriteLine("任务是否完成：" + task3.IsCompleted);
Console.ReadKey();
}
public static void GetResult(bool isCancel, bool isFault)
{
if (isCancel == false && isFault == false)
Console.WriteLine("没有异常发生");
else if (isCancel == true)
Console.WriteLine("任务被取消");
else
Console.WriteLine("任务引发了未经处理的异常");
}
}
再说父子任务
在上一篇文章中《C#多线程(13)：任务基础①》，我们学习了父子任务，父任务需要等待子任务完成后才算完成任务。
上一章只是给出示例，没有明确说明场景和实验结果，这里重新写一个示例来补充。
非父子任务：
外层任务不会等待内嵌的任务完成，直接完成或返回结果。
static void Main()
{
//两个任务没有从属关系，是独立的
Task<int> task = new Task<int>(() =>
{
// 非子任务
Task task1 = new Task(() =>
{
Thread.Sleep(TimeSpan.FromSeconds(1));
for (int i = 0; i < 5; i++)
{
Console.WriteLine(" 内层任务1");
Thread.Sleep(TimeSpan.FromSeconds(0.5));
}
});
task1.Start();
return 666;
});
task.Start();
Console.WriteLine($"任务运算结果是：{task.Result}");
Console.WriteLine("\n-------------------\n");
Console.ReadKey();
}
父子任务：
父任务等待子任务完成后，才能算完成任务，然后返回结果。
static void Main()
{
// 父子任务
Task<int> task = new Task<int>(() =>
{
// 子任务
Task task1 = new Task(() =>
{
Thread.Sleep(TimeSpan.FromSeconds(1));
for (int i = 0; i < 5; i++)
{
Console.WriteLine(" 内层任务1");
Thread.Sleep(TimeSpan.FromSeconds(0.5));
}
}, TaskCreationOptions.AttachedToParent);
task1.Start();
Console.WriteLine("最外层任务");
return 666;
});
task.Start();
Console.WriteLine($"任务运算结果是：{task.Result}");
Console.WriteLine("\n-------------------\n");
Console.ReadKey();
}
组合任务/延续任务
Task.ContinueWith() 方法创建一个在 任务(Task)实例 完成时异步执行的延续任务。
Task.ContinueWith() 的重载方法非常多，可以参考：https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.tasks.task.continuewith?view=netcore-3.1#--
这里我们使用的构造函数定义如下：
public Task ContinueWith(Action<Task> continuationAction);
一个简单的示例：
Task task = new Task(() =>
{
Console.WriteLine(" 第一个任务");
Thread.Sleep(TimeSpan.FromSeconds(2));
});
// 接下来第二个任务
task.ContinueWith(t =>
{
Console.WriteLine($" 第二个任务}");
Thread.Sleep(TimeSpan.FromSeconds(2));
});
task.Start();
一个任务(Task) 是可以设置多个延续任务的，这些任务是并行的，例如：
static void Main()
{
Task task = new Task(() =>
{
Console.WriteLine(" 第一个任务");
Thread.Sleep(TimeSpan.FromSeconds(1));
});
// 任务①
task.ContinueWith(t =>
{
for (int i = 0; i < 5; i++)
{
Console.WriteLine($" 任务① ");
Thread.Sleep(TimeSpan.FromSeconds(1));
}
});
// 任务②
task.ContinueWith(t =>
{
for (int i = 0; i < 5; i++)
{
Console.WriteLine($" 任务②");
Thread.Sleep(TimeSpan.FromSeconds(1));
}
});
// 任务① 和 任务② 属于同级并行任务
task.Start();
}
