using System;

using System.Threading;

using System.Threading.Tasks;

using System.Threading.Channels;

using System.Collections.Concurrent;

​

//var c = Channel.CreateUnbounded<WorkItem>();

​

//static Task Schedule(ChannelWriter<WorkItem> writer, int value)

//{

//  var wi = new WorkItem{ value = value, tcs = new TaskCompletionSource() };

//  writer.WriteAsync(wi).GetAwaiter().GetResult();

//  return wi.tcs.Task;

//}

​

//new Thread (async () => {

//    await foreach (var wi in c.Reader.ReadAllAsync())

//  {

//      //Thread.Sleep(10000);

//      Console.WriteLine(wi.value);

//      wi.tcs.SetResult();

//  }

//}).Start();

​

///////////////////////////////////////////////////

​

var bc = new BlockingCollection<WorkItem>();

static Task ScheduleBc(BlockingCollection<WorkItem> bc, int value)

{

    var wi = new WorkItem{ value = value, tcs = new TaskCompletionSource() };

    bc.Add(wi);

    return wi.tcs.Task;

}

​

new Thread (() => {

    foreach (var wi in bc.GetConsumingEnumerable())

    {

        //Thread.Sleep(10000);

        Console.WriteLine(wi.value);

        wi.tcs.SetResult();

    }

}).Start();

​

Console.WriteLine("0");

​

​

//async Task asdasd(){

    await ScheduleBc(bc, 1);

    //snmpp.Write();

    //Thread.Sleep(10000);

​

    Console.WriteLine("-1");

    await ScheduleBc(bc, 2);

    Console.WriteLine("-2");

    await ScheduleBc(bc, 3);

    Console.WriteLine("-3");

​

    bc.CompleteAdding();

//}

​

​

class WorkItem

{

    public TaskCompletionSource tcs;

    public int value;

}

​

​