在delphi中使用go语言的并发编程方法，增加demo3

[color=#000080][b]program[/b][/color] [color=#000000]demo3[/color];

[i]{$APPTYPE CONSOLE}[/i]

[color=#000080][b]uses[/b][/color]
  [color=#000000]SysUtils[/color][color=#000000],[/color][color=#000000]Generics[/color][color=#000000].[/color][color=#000000]Collections[/color][color=#000000],[/color]
  [color=#000000]coroutineUnit[/color];

[color=#006400]//这个例子演示了如何实现超时控制[/color]
[color=#006400][/color]
[color=#000080][b]var[/b][/color]
    [color=#000000]cWork[/color][color=#000000],[/color] [color=#000000]cTimeout[/color][color=#000000]:[/color] [color=#000000]CChannel[/color][color=#000000]<[/color][color=#000080][b]Integer[/b][/color][color=#000000]>; [color=darkgreen]//声明两个通道，各用于工作和超时[/color][/color]
    [color=#000000]ret[/color][color=#000000]:[/color] [color=#000000]tpair[/color][color=#000000]<[/color][color=#000080][b]Integer[/b][/color][color=#000000],[/color] [color=#000080][b]Integer[/b][/color][color=#000000]>; [color=#006400]//后面有讲到[/color][/color]
[color=#000080][b]begin[/b][/color]
[color=#000000]cWork[/color][color=#000000]:=[/color][color=#000000]CChannel[/color][color=#000000]<[/color][color=#000080][b]Integer[/b][/color][color=#000000]>.[/color][color=#000000]create[/color];
[color=#000000]cTimeout[/color][color=#000000]:=[/color][color=#000000]CChannel[/color][color=#000000]<[/color][color=#000080][b]Integer[/b][/color][color=#000000]>.[/color][color=#000000]create[/color];

[color=#000000]go[/color]([color=#000080][b]procedure[/b][/color]() [color=#006400]//起动工作线程[/color]
    [color=#000080][b]var[/b][/color]
        [color=#000000]i[/color][color=#000000]:[/color] [color=#000080][b]Integer[/b][/color];
    [color=#000080][b]begin[/b][/color]
    [color=#000000]sleep[/color]([color=#0000ff]1010[/color]);  [color=#006400]//假设这个工作费时1010毫秒[/color]
    [color=#000080][b]try[/b][/color]
        [color=#000000]cWork[/color][color=#000000].[/color][color=#000000]value[/color][color=#000000]:=[/color][color=#0000ff]1[/color];  [color=#006400]//发通道发送一个值，表示工作完成了。[/color]
    [color=#000080][b]except[/b][/color]
        [color=#000080][b]end[/b][/color];
    [color=#000080][b]end[/b][/color]);

[color=#000000]go[/color]([color=#000080][b]procedure[/b][/color]()  [color=#006400]//起动一个线程用来计时[/color]
    [color=#000080][b]begin[/b][/color]
    [color=#000000]sleep[/color]([color=#0000ff]1000[/color]);  [color=#006400]//假设超时等待时间是1秒[/color]
    [color=#000000]cTimeout[/color][color=#000000].[/color][color=#000000]value[/color][color=#000000]:=[/color][color=#0000ff]1000[/color]; [color=#006400]//...[/color]
    [color=#000080][b]end[/b][/color]);

[color=#006400]{直到cWork,cTimeout这两个通道至少有一个可读取，获取通道的结果，结果是个pair，其中key描述了哪个通道有响应，value描述了通道的值（对这个select的模仿远没有go语言的幽雅，也许以后会有更好的办法）}[/color]
[color=#000000]ret[/color][color=#000000]:=[/color][color=#000000]CCoroutine[/color][color=#000000].[/color][color=#000000]select[/color][color=#000000]<[/color][color=#000080][b]Integer[/b][/color][color=#000000]>[/color][color=#000000]([[/color][color=#000000]cWork[/color][color=#000000],[/color] [color=#000000]cTimeout[/color][color=#000000]])[/color];  
[color=#000080][b]case[/b][/color] [color=#000000]ret[/color][color=#000000].[/color][color=#000000]key[/color] [color=#000080][b]of  [color=#006400]//判断是哪个通道可读[/color][/b][/color]
    [color=#0000ff]0[/color][color=#000000]:[/color]    [color=#000000]Writeln[/color]([color=#0000ff]'完成'[/color]);  [color=#006400]//如果是第0个，就是cWork的信号了，表示在超时等待之前工作完成了。[/color]
    [color=#0000ff]1[/color][color=#000000]:[/color]    [color=#000000]Writeln[/color]([color=#0000ff]'超时'[/color][color=#000000]+[/color][color=#000000]inttostr[/color]([color=#000000]ret[/color][color=#000000].[/color][color=#000000]value[/color]));  [color=#006400]//...[/color]
    [color=#000080][b]end[/b][/color];

[color=#000000]cWork[/color][color=#000000].[/color][color=#000000]Free[/color];
[color=#000000]cTimeout[/color][color=#000000].[/color][color=#000000]Free[/color];
[color=#000000]Readln[/color];
[color=#000080][b]end[/b][/color][color=#000000].[/color]

附件中只有coroutineUnit.pas，没有相应的dpr文件？

:D

多谢分享啊