C / C++ / MFC

class SockCLeintThread : public CWinThread {
   public:
	   //   DECLARE_DYNCREATE(SockCLeintThread)
      //  DECLARE_DYNAMIC(SockCLeintThread)
       //     IMPLEMENT_DYNAMIC(SockCLientThread)
        public:
		SockCLeintThread(UINT myport);
		~SockCLeintThread();
                CWnd *sendwindow;
                CWnd *call_wnd;
       		char *thread_id;
                SockClient thisocket;            // Socket to do ocommunication
                virtual BOOL InitInstance();      // Just for starters
                void Sendit(WPARAM, LPARAM);
		void Receiveit(WPARAM, LPARAM);
		LPCTSTR ipaddr;
                BOOL idle;				 // looking for work
		allexceptions myallexception;
				 
		struct {
			unsigned int is_connected : 1;
			unsigned int busy : 1;
			} flags;
				
protected:
           DECLARE_MESSAGE_MAP()

};

class SockClient : public CAsyncSocket
{
 public:
      // SockCleint(char *sockptr);
         SockClient(UINT myport);
         char *sockbuffer;		// send and receive buffer
         int num_buff;
	CWnd *send_wnd;
	int thread_no;
	UINT port;
	private:
		int busy;               // inuse
		               // port used by this class
   protected:
                         // window to send message to
        virtual void OnReceive(int nErrorCode);
        virtual void OnSend(int nErrorCode);
        virtual void OnConnect(int nErrorCode);
		virtual void OnClose(int nErrorCode);

     for (i = 0, start_port = 11007; i < 4; start_port++, i++)
{
        threadptr[i] = new SockCLeintThread(start_port);

      if (threadptr[i] == NULL)
         m_pMainWnd->MessageBox("SockClientThreadFail",NULL,MB_ICONERROR);

          threadptr[i]->CreateThread(CREATE_SUSPENDED,0,NULL);

          threadptr[i]->flags.is_connected = 0;

           threadptr[i]->ipaddr = "192.168.1.4";                   // ip address

           SetThreadName(threadptr[i]->m_nThreadID,thread[i]);

             threadptr[i]->ResumeThread();

    }

SockCLeintThread::SockCLeintThread(UINT myport) : thisocket(myport)
{
        m_bAutoDelete = FALSE;
}

SockClient::SockClient(UINT myport)
 {
	port = myport;
        sockbuffer = new char[300];

 }

 OOL SockCLeintThread::InitInstance()
   {
int error_code;
MSG m_msgCur;
extern void SetThreadName( DWORD dwThreadID, LPCSTR szThreadName);
         



	 
		 if(thisocket.Create(thisocket.port,SOCK_STREAM,NULL)== 0)
         {
                         error_code =  GetLastError();
                  }

             if (thisocket.AsyncSelect   (FD_CONNECT|FD_CLOSE|FD_OOB|FD_ACCEPT) == 0) 
			                   error_code =  GetLastError();
			 

       

          


          if( thisocket.Connect(ipaddr,thisocket.port) == 0)
                  {
		                         error_code =  GetLastError();
                  }
		   else
				 	  flags.is_connected = 1;
		  
			   
  PeekMessage(&m_msgCur, NULL, NULL, NULL, PM_NOREMOVE);   // Create Message Queue



    return TRUE;                                                   // [11]
   }