От: | cadet354 | my twitter | |
Дата: | 26.11.08 08:57 | ||
Оценка: |
private static void Main(string[] args)
{
var dispatcher = new Dispatcher();
var taskQueue = new DispatcherQueue("simple queue", dispatcher);
var port_set = new PortSet<int, Exception>();
Arbiter.Activate(taskQueue,
Arbiter.Choice(port_set,
val =>
{
Console.WriteLine("{0} time={1}", val, DateTime.Now);
},
exc => Console.WriteLine(exc.Message))
);
port_set.Post(new Exception("test exception"));
//Thread.Sleep(250); если раскоментировать то выведет test exception
port_set.Post(10); //выводит 10
}
я думал, что первым придет то и отработаетThe Choice operates a simple first-come, first-served policy