using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.IO;

using SocketIM;

using System.Net;

using System.Net.Sockets;

using ConsoleApplication1;

using System.Runtime.Remoting.Messaging;

using System.Threading;

namespace ConsoleApplication2

{

    public interface IIMCallBack

    {

        void IMCallBack(byte[] data);

    }

    public class ServerHandler : IIMCallBack

    {

        public void IMCallBack(byte[] data)

        {

            string str = System.Text.Encoding.UTF8.GetString(data);

            var dic = Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<string, string>>(str);

            if (dic["MessageType"] == "")

            {

                Console.WriteLine();

            }

            else if (dic["MessageType"] == "")

            {

                Console.WriteLine();

            }

            System.Threading.Thread thread = new System.Threading.Thread(StartListening);

            thread.IsBackground = true;

            thread.Start();

        }

        public static void StartListening()

        {

            //byte[] bytes = new Byte[1024];

            IPAddress ipAddress = IPAddress.Parse("127.0.0.1");

            IPEndPoint localEndPoint = new IPEndPoint(ipAddress, );

            // Create a TCP/IP socket.

            Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // Bind the socket to the local

            //endpoint and listen for incoming connections.

            try

            {

                listener.Bind(localEndPoint);

                listener.Listen();

                while (true)

                {

                    listener.BeginAccept(new AsyncCallback(AcceptCallback), listener);

                }

            }

            catch (Exception e)

            {

                Console.WriteLine(e.ToString());

            }

            Console.WriteLine("\nPress ENTER to continue...");

            Console.Read();

        }

        public static void AcceptCallback(IAsyncResult ar)

        {

            Socket listener = (Socket)ar.AsyncState;

            Socket handler = listener.EndAccept(ar);

            byte[] buff = new byte[];

            while (true)

            {

                handler.BeginReceive(buff, , , , new AsyncCallback(ReadCallback),handler);

            }

        }

        public static void ReadCallback(IAsyncResult ar)

        {

            String content = String.Empty;

            // Retrieve the state object and the handler socket

            // from the asynchronous state object.

            Socket state = (Socket)ar.AsyncState;

            // Read data from the client socket.

            int bytesRead = state.EndReceive(ar);

            byte[] buff = new byte[];

        }

    }

}

public delegate int AddEvent(int a, int b);

class Program

{

    public class StateObject

    {

        public string key { get; set; }

        public bool state { get; set; }

    }

    public static List<int> bags = new List<int>();

    static void Main(string[] args)

    {

        ManualResetEvent t = new ManualResetEvent(false);

        Dictionary<int, StateObject> dicDone = new Dictionary<int, StateObject>();

        dicDone.Add(, new StateObject() { key="",state=false });

        dicDone.Add(, new StateObject() { key = "", state = false });

        dicDone.Add(, new StateObject() { key = "", state = false });

        AddEvent add = (a, b) =>

        {

            int r= a + b;

            bags.Add(r);

            return r;

        };

        add.BeginInvoke(, , callback, dicDone[]);

        add = (a, b) =>

        {

            int r = a + b;

            bags.Add(r);

            return r;

        };

        add.BeginInvoke(, , callback, dicDone[]);

        add = (a, b) =>

        {

            Thread.Sleep();

            int r = a + b;

            bags.Add(r);

            return r;

        };

        add.BeginInvoke(, , callback, dicDone[]);

        Thread th = new Thread((o) =>

        {

            while (true)

            {

                int cx = dicDone.Keys.Count;

                int x = ;

                foreach (var item in dicDone)

                {

                    if (item.Value.state == true)

                    {

                        x++;

                    }

                }

                if (x == cx)

                {

                    t.Set();

                    Console.WriteLine("resutl is：");

                    foreach (var item in bags)

                    {

                        Console.WriteLine(item);

                    }

                    break;

                }

            }

        });

        th.Start();

        t.WaitOne();

        Console.WriteLine("队列完成！！");

        //SocketTest.Send("127.0.0.1", 11000, "www.jb51.net");

        Console.Read();

    }

    private static void callback(IAsyncResult ar)

    {

        var handler = (AddEvent)((AsyncResult)ar).AsyncDelegate;

        var state = ar.AsyncState as StateObject;

        state.state = true;

        Console.WriteLine(state.key+"线程放行！！");

        Console.WriteLine(ar.AsyncState);

    }

}