[root@virtdb56 ~]# vi mythread.py
#!/usr/bin/env python
#-*- coding: UTF-8 -*-

import pymongo
import threading
import sys
import random

import MySQLdb as mdb
import os,time,sys
import commands as co
import datetime

def myinsert(i, num_of_op):
for row in range(0,int(num_of_op)):
con_2 = mdb.connect('192.168.2.52','root','123456','test')
cur_2 = con_2.cursor()
v_name = str(row)+'_'+'chen'
cur_2.execute("insert into test.t1 (id,name) values(%s,%s)",(row,v_name))
con_2.commit()
select = "select * from t1 where name = '%s'" % (v_name)
cur_2.execute(select)

if __name__ == "__main__":
args = sys.argv
num_of_thd = args[1]
num_of_op = args[2]
threads = []
for i in range(0, int(num_of_thd)):
threads.append(threading.Thread(target=myinsert, args=(i, num_of_op)))

for t in threads:
t.start()

for t in threads:
t.join()

python mythread.py 1000 50000

ITPub博客

Python threading多线程

最新文章