[普通]muti_thread是一个真正的多并发多线程

作者(passion) 阅读(87次) 评论(0) 分类( 程序)

muti_thread是一个真正的多并发多线程,python3.6


pip install muti-thread


# -*- coding: utf-8 -*-
import time
from muti_thread.muti_thread import thread_create,thread_append,thread_start_and_join
import numpy as np

vec1 = [1,2,3,4,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]
vec2 = [5,6,7,8,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]

def my_compute(n=10000):
    for i in range(n):
        dist1 = np.dot(vec1, vec2) / (np.linalg.norm(vec1) * np.linalg.norm(vec2))

class thread_param:
    def __init__(self,index):
        self.counter = 0
        self.index = index

#必须有且只有一个参数,最好是某个类的实例
#注意 , 线程函数里最好不要有import的东西 ,里面最好是执行函数
def thread_func(param):
    param.counter += 1
    #测试1万次
    my_compute()
    # if param.counter> 10000:
    #     print(param.index ,'end')
    #     return -1
    return -1 #// 返回值小于0  退出线程 , 0 继续循环执行线程函数


def main():
    start = float(round(time.time() * 1000))
    resource = thread_create()
    #并发线程
    for i in range(4):
        param = thread_param(i)
        thread_append(resource, thread_func, param)
    #开始并等待线程结束
    thread_start_and_join(resource)
    end = float(round(time.time() * 1000))
    print('run time {}'.format (end-start))

if __name__ == '__main__':
    main()


« 上一篇:关系重叠?实体嵌套?曝光偏差?这个模型统统都搞得定!
« 下一篇:muti-thread 推理tensorflow
在这里写下您精彩的评论
  • 微信

  • QQ

  • 支付宝

返回首页
返回首页 img
返回顶部~
返回顶部 img
';