inprocworkers

        [Test]
        public void InProcWorkers()
        {
            int count = 100;
            int workers = 10;

            using (NetMQContext context = NetMQContext.Create())
            {
                using (var response = context.CreateResponseSocket())
                {
                    response.Bind("inproc://rep");

                    Action action = () =>
                    {
                        using (var request = context.CreateRequestSocket())
                        {
                            request.Connect("inproc://rep");

                            for (int i = 0; i < count; i++)
                            {
                                request.Send(i.ToString());
                                request.ReceiveString();
                            }
                        }
                    };

                    for (int i = 0; i < workers; i++)
                    {
                        Task.Factory.StartNew(action);    
                    }

                    for (int i = 0; i < workers*count; i++)
                    {
                        string message = response.ReceiveString();
                        Console.WriteLine(message);
                        response.Send(i.ToString());
                    }
                }
            }
        }