[Test]
        public void FewTasks_FewProducers_Success() {
            const int expectedCount = 1000;
            var executed = 0;
            
            var taskMock = new Mock<ITask>();
            taskMock.Setup(t => t.Run()).Callback(() => Interlocked.Increment(ref executed));
            
            var dispatcher = new DefaultTaskDispatcher();
            dispatcher.Start();

            var cts = new CancellationTokenSource();

            var runned = 0;
            var producerAction = new Action(() =>
            {
                while (runned != expectedCount) {
                    try {
                        dispatcher.Dispatch(taskMock.Object);

                        Interlocked.Increment(ref runned);
                    } catch (OverflowException) {
                        Thread.Sleep(1000);
                    }
                }
            });

            var tasks = new List<Task>()
            {
                Task.Run(producerAction, cts.Token)
                ,Task.Run(producerAction, cts.Token)
                //,Task.Run(producerAction, cts.Token)
                //,Task.Run(producerAction, cts.Token)
                //,Task.Run(producerAction, cts.Token)
                //,Task.Run(producerAction, cts.Token)
                //,Task.Run(producerAction, cts.Token)
            };
            Task.WaitAll(tasks.ToArray());
            
#if DEBUG
            var list = dispatcher.StopDebug();
            Assert.AreEqual(0, list.Count);
#endif

            Assert.AreEqual(expectedCount, executed);
        }

while (runned != expectedCount) {