這篇文章主要介紹Python編程scoketServer如何實(shí)現(xiàn)多線程同步，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

10年積累的成都網(wǎng)站制作、成都做網(wǎng)站經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先制作網(wǎng)站后付款的網(wǎng)站建設(shè)流程，更有水富免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

具體介紹如下。

開發(fā)過程中，為了實(shí)現(xiàn)不同的客戶端同一時(shí)刻只能有一個(gè)使用共同數(shù)據(jù)。

雖說用Python編寫簡(jiǎn)單的網(wǎng)絡(luò)程序很方便，但復(fù)雜一點(diǎn)的網(wǎng)絡(luò)程序還是用現(xiàn)成的框架比較好。這樣就可以專心事務(wù)邏輯，而不是套接字的各種細(xì)節(jié)。SocketServer模塊簡(jiǎn)化了編寫網(wǎng)絡(luò)服務(wù)程序的任務(wù)。同時(shí)SocketServer模塊也是Python標(biāo)準(zhǔn)庫中很多服務(wù)器框架的基礎(chǔ)。

網(wǎng)絡(luò)服務(wù)類：

SocketServer提供了4個(gè)基本的服務(wù)類：

TCPServer針對(duì)TCP套接字流
UDPServer針對(duì)UDP數(shù)據(jù)報(bào)套接字
UnixStreamServer和UnixDatagramServer針對(duì)UNIX域套接字，不常用。

首先，明確一點(diǎn)，在scoketServer中，每當(dāng)有一個(gè)客戶端連接成功后都會(huì)為每個(gè)客戶端創(chuàng)建一個(gè)線程。

為了讓這些多線程之間能夠同步執(zhí)行，我的做法是：再創(chuàng)建一個(gè)線程類，這個(gè)線程類中做一些我的項(xiàng)目需要做的事情，，當(dāng)某個(gè)客戶端想成使用到這個(gè)線程時(shí)，給當(dāng)前線程加鎖，運(yùn)行完成后釋放鎖。

請(qǐng)指教

詳細(xì)步驟請(qǐng)看注釋：

#coding=gbk
__author__ = 'kaikai'

import Queue
import threading
import time
import SocketServer

#全局線程鎖
threadLock = threading.Lock()#全局?jǐn)?shù)據(jù)隊(duì)列
data = Queue.Queue()
#工作線程類，
class testThead(threading.Thread):
  global data
 def __init__(self):
    threading.Thread.__init__(self)

  def begin_test(self):
    self.start()

  def run(self):
    global threadLock
    
    threadLock.acquire()

    # 從隊(duì)列中取出連接和數(shù)據(jù)
    if data.qsize()>0:
      this_receive = data.get()
    else:
      print "data size is empty !"
      return

    # 解析數(shù)據(jù)，獲得連接和數(shù)據(jù)
    # 使用當(dāng)前數(shù)據(jù)的conn
    this_conn = this_receive.keys()[0]
    this_data = this_receive[this_conn]

    # 釋放鎖
    threadLock.release()

  def send_msg(self,conn,msg):
    try:
      conn.sendall(msg)
    except Exception as e:
      print "send " + str(msg) +"fail !!!!!!!!!!!!!!"

  def recv_msg(self,conn):
    try:
      recv_msg = conn.recv(2048)
      return recv_msg
    except Exception as e:

      print " recv msg fail !!!!!!!!!!"
      return None

# 每有一個(gè)客戶端生成一個(gè)線程。所有線程調(diào)用同一個(gè)測(cè)試線程，如果測(cè)試線程在鎖定中，則進(jìn)入等待。
class MyServer(SocketServer.BaseRequestHandler):

  def send_msg(self,conn,msg):
    try:
      conn.sendall(msg)
    except Exception as e:
      print "send " + str(msg) +"fail !!!!!!!!!!!!!!"
  def recv_msg(self,conn):
    try:
      recv_msg = conn.recv(2048)
      return recv_msg
    except Exception as e:

      print " recv msg fail !!!!!!!!!!"

  def handle(self):
    global data
    # 獲得連接
    conn = self.request

    print "client connect!"

    # 循環(huán)接受客戶端數(shù)據(jù)
    while True:
      # 接受客戶端發(fā)送過來的參數(shù)
      receive_data = self.recv_msg(conn)

      print receive_data
      # 如果參數(shù)為空，返回報(bào)錯(cuò) 結(jié)束循環(huán)
      if not receive_data:
        print "can not get data form client ! "
        break

      print "data size put before: " + str(data.qsize())
      # 將連接和數(shù)據(jù)添加到隊(duì)列中 放入連接可以保證在另一個(gè)線程中直接使用連接給相應(yīng)客戶端發(fā)送或者接受數(shù)據(jù)。同時(shí)保證數(shù)據(jù)與客戶端的一一對(duì)應(yīng)
      data.put({conn:receive_data})

      print "data size put aftter: " + str(data.qsize())
      # 初始化測(cè)試線程
      testThead_this = testThead()
      # 開始測(cè)試線程
      testThead_this.begin_test()
      # testThead_this.start()
      # 等待測(cè)試線程執(zhí)行結(jié)束
      testThead_this.join()

      print "this test end "

if __name__ == "__main__" :
  try:
    server = SocketServer.ThreadingTCPServer(('192.168.100.100',56780),MyServer)
    server.timeout = 100
    print "Server run success !!!! "

    server.serve_forever()

  except Exception as e:
    print "Server run failed !!!!\n  error: " + str(e)

以上是“Python編程scoketServer如何實(shí)現(xiàn)多線程同步”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計(jì)公司行業(yè)資訊頻道！

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

網(wǎng)站標(biāo)題：Python編程scoketServer如何實(shí)現(xiàn)多線程同步-創(chuàng)新互聯(lián)
轉(zhuǎn)載來于：http://weahome.cn/article/dgdced.html