本文研究的主要是Python编程scoketServer实现多线程同步的相关内容，具体介绍如下。
开发过程中，为了实现不同的客户端同一时刻只能有一个使用共同数据。
虽说用Python编写简单的网络程序很方便，但复杂一点的网络程序还是用现成的框架比较好。这样就可以专心事务逻辑，而不是套接字的各种细节。SocketServer模块简化了编写网络服务程序的任务。同时SocketServer模块也是Python标准库中很多服务器框架的基础。
网络服务类：
SocketServer提供了4个基本的服务类：
TCPServer针对TCP套接字流
UDPServer针对UDP数据报套接字
UnixStreamServer和UnixDatagramServer针对UNIX域套接字，不常用。
首先，明确一点，在scoketServer中，每当有一个客户端连接成功后都会为每个客户端创建一个线程。
为了让这些多线程之间能够同步执行，我的做法是：再创建一个线程类，这个线程类中做一些我的项目需要做的事情，，当某个客户端想成使用到这个线程时，给当前线程加锁，运行完成后释放锁。
请指教
详细步骤请看注释：
#coding=gbk
__author__ = 'kaikai'
import Queue
import threading
import time
import SocketServer
#全局线程锁
threadLock = threading.Lock()#全局数据队列
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()
# 从队列中取出连接和数据
if data.qsize()>0:
this_receive = data.get()
else:
print "data size is empty !"
return
# 解析数据，获得连接和数据
# 使用当前数据的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
# 每有一个客户端生成一个线程。所有线程调用同一个测试线程，如果测试线程在锁定中，则进入等待。
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!"
# 循环接受客户端数据
while True:
# 接受客户端发送过来的参数
receive_data = self.recv_msg(conn)
print receive_data
# 如果参数为空，返回报错 结束循环
if not receive_data:
print "can not get data form client ! "
break
print "data size put before: " + str(data.qsize())
# 将连接和数据添加到队列中 放入连接可以保证在另一个线程中直接使用连接给相应客户端发送或者接受数据。同时保证数据与客户端的一一对应
data.put({conn:receive_data})
print "data size put aftter: " + str(data.qsize())
# 初始化测试线程
testThead_this = testThead()
# 开始测试线程
testThead_this.begin_test()
# testThead_this.start()
# 等待测试线程执行结束
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实现多线程同步实例代码的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。