python 多线程处理

python 多线程处理还是很方便

# coding=utf-8
from datetime import datetime
import pymysql.cursors
from faker import Factory
import random
import threading


#假数据制造工厂
faker = Factory.create('zh_CN')

def insert_data(threadName,num):
    print 'run %s...'%(threadName)
    mysql_conn = pymysql.connect(host= '127.0.0.1',
                             user= 'root',
                             password= '',
                             db= 'das',
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)
    with mysql_conn.cursor() as cursor:
        for _ in range(0,10):
            create_time = faker.date_time_between_dates(datetime(2017,4,10),datetime(2017,5,10))
            order_id = random.randint(1,30)
            order_status = random.randint(1,5)
            sql = "insert into `order` (`order_date_time`,`order_id`,`order_status`) values ('%s','%s','%s')" %(create_time,order_id,order_status)
            print sql
            cursor.execute(sql)
            mysql_conn.commit()
    mysql_conn.close()

#定义我的多线程处理
class myThread(threading.Thread):

    def __init__(self,name,num):
        threading.Thread.__init__(self)
        self.name = name
        self.num = num

    def run(self):
        insert_data(self.name,self.num)

#启动4个线程插入数据
threads = []
for i in range(1,5):
    name = 'thread-%s' %(i)
    new_th = myThread(name,50)
    new_th.start()
    threads.append(new_th)

for t in threads:
    t.join()
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 线程和进程 计算机,用于计算的机器。计算机的核心是CPU,在现在多核心的电脑很常见了。为了充分利用cpu核心做计算...
    人世间阅读 24,369评论 3 85
  • # Python 资源大全中文版 我想很多程序员应该记得 GitHub 上有一个 Awesome - XXX 系列...
    aimaile阅读 26,596评论 6 427
  • 文/不妥协的纽扣 后知后觉,四月已过半。 来不及,写一些文字,怀念那早些年也一样不知不觉过了的四月情。 小城的春意...
    疯狂稻草人阅读 437评论 4 2
  • 鼓乐喧天辞旧岁,笙歌唱响,红浪翻飞,烹牛宰羊且为醉。 喧嚣难掩囊中羞,三杯粗茶,两盏淡酒,一夜愁绪白了头。
    古都草堂人阅读 507评论 0 0
  • 我会了化妆会了护肤找到了自己的风格活成了我自己,只是还带着你的影响,依旧还是看到什么第一个想到你,只是不再与你分享...
    陪你度过漫长岁月的VV阅读 304评论 0 0