Natural Language Processing, Topic Modeling, Neural Text Generation and Ali Xiaomi

Size: px

Start display at page:

Download "Natural Language Processing, Topic Modeling, Neural Text Generation and Ali Xiaomi"

糊花
5 years ago
Views:

1 并行计算 :Parallel Computing 结构编程算法应用 3.4 Python 并发程序设计徐悦甡 (Yueshen Xu) 软件工程系西安电子科技大学

2 本节提纲 Python 语言基础 Python 基础语法 Python 面向对象编程 Python 并发程序设计 (Concurrency) Python 多线程机制 Python 中线程的创建 Python 语言 Python 并发编程关键字 : Python 基础语法变量与运算并发编程 2

3 参考方法一 : 将要执行的函数作为参数传递给 threading.thread() #!/usr/bin/env python3 # -*- coding:utf-8 -*- import threading, time def func(n): global count time.sleep(0.1) for i in range(n): count += 1 #def ends if name == main : count = 0 threads = [] for i in range(5): threads.append(threading.thread(target =func, args=(1000,))) for t in threads: t.start() time.sleep(5) print( count:,count) #main ends 3

4 代码分析 threading.thread(target=func, args=(1000,)) - func 为函数名,args 为函数参数 ( 必须以元组的形式传递 ); t.start(): 启动函数, 等待操作系统调度 ; 函数运行结束, 线程也就结束 ; time.sleep(): 线程进入睡眠, 处于 IO 阻塞状态结果分析以上例子创建了 5 个线程去执行 func 函数获得的结果可能是 5000, 但也有时候会出现错误 4

5 参考方法二 : 继承 threading.thread() 类, 并重写 run()( 推荐使用 ) #!/usr/bin/env python3 # -*- coding:utf-8 -*- import threading, time class mythread(threading.thread): def init (self, n): threading.thread. init (self) self.mythread_n = n def run(self): global count for i in range(self.mythread_n): count += 1 #def ends if name == main : count = 0 threads = [] for i in range(5): threads.append(mythread(1000)) for t in threads: t.start() time.sleep(5) print( count:,count) 5

6 线程同步锁互斥控制 class mythread(threading.thread): def init (self, n): threading.thread. init (self) self.mythread_n = n def run(self): global count for i in range(self.mythread_n): count += 1 #def ends class mythread(threading.thread): def init (self, n): threading.thread. init (self) self.mythread_n = n def run(self): global count for i in range(self.mythread_n): Temp = count time.sleep(0.0001) count = Temp + 1 #def ends 6

7 线程同步锁互斥控制 import threading, time class mythread(threading.thread): def init (self, n): threading.thread. init (self) self.mythread_n = n def run(self): global count for i in range(self.mythread_n): if lock.acquire(): Temp = count time.sleep(0.0001) count = Temp + 1 lock.release() if name == main : count = 0 # 同步锁, 也称互斥量 lock = threading.lock() threads = [] for i in range(5): threads.append(mythread(1000)) for t in threads: t.start() time.sleep(5) print( count:,count) 7

8 线程同步锁互斥控制代码分析 lock = threading.lock(): 创建锁 ; b. lock.acquire([timeount]): 请求锁定, - 如果设定了 timeout, 则在超时后通过返回值可以判断是否得到了锁, - 从而可以进行一些其他的处理 ; c. lock.release(): 释放锁定 8

9 threading: 信号量信号量用来控制线程并发数的 BoundedSemaphore 或 Semaphore 管理一个内置的计数器 - 每当调用 acquire() 时 -1, - 调用 release() 时 +1 计数器不能小于 0, 当计数器为 0 时,acquire() 将阻塞线程至同步锁定状态, 直到其他线程调用 release() BoundedSemaphore 与 Semaphore 的唯一区别在于 - 前者将在调用 release() 时检查计数器的值是否超过了计数器的初始值 - 如果超过将抛出一个异常 9

10 threading: 信号量 #!/usr/bin/env python3 # -*- coding:utf-8 -*- import threading, time class mythread(threading.thread): def run(self): if semaphore.acquire(): # 注意观察 semaphore print(self.name) time.sleep(5) semaphore.release() if name == main : semaphore = threading.semaphore(5) threads = [] for i in range(100): threads.append(mythread()) for t in threads: t.start() 10

11 threading: 其他函数 threading.timer() Thread 的派生类, 用于在指定时间后调用一个方法 threading.join() 使得一个线程可以等待另一个线程执行结束后再继续运行 threading.isalive() 判断线程是否还在运行中 threading.isdaemon() 返回线程的 daemon 标志 threading.getname() 返回线程名 threading.current_thread() 返回当前线程句柄 threading.enumerate() 返回正在运行的线程列表 threading.activecount() 返回正在运行的线程数量 11

12 第四次上机时间与地点 6 月 27 号, G 楼机房主题 :Python 并发编程题目与 Java 并发编程题目相同题目一 : 四个售票窗口同时出售 30 张电影票参考思路 - 票数要使用同一个静态值 - 为保证不会出现卖出同一个票数, 要 Python 多线程同步锁 - 创建一个售票窗口类 BoxOffice, 继承 threading.thread, 重写 run 方法, 在 run 方法里面执行售票操作 - 售票要使用同步锁 : 即有一个站台卖这张票时, 其他站台要等这张票卖完 12

13 第四次上机题目二 - 两个人张三与李四, 通过一个同一个账户, 张三在柜台取钱, 李四在 ATM 机取钱参考思路 - 创建一个 Bank 类 - 创建一个张三类, 代表在柜台取钱 - 创建一个李四类, 代表在 ATM - 创建主方法的调用类

14 第四次上机要求完成两道题目的程序编写, 独立完成实验报告, 发送电子版, 可以是 word, 也可以 pdf 实验报告提交地址, 同作业邮件命名规则 : 实验报告四 + 学号 + 姓名附件命名规则 : 实验报告四 + 学号 + 姓名上交时间 : 至 7.6 号星期五, 十天时间实验报告格式 : 见并行计算实验报告结构及要求 14

15 附上机整体安排上机时间 ( 四次,16 学时 ) 按周数 : 第周的星期三按日期 :5 月 16 号,5 月 23 号,6 月 6 号,6 月 27 号全部为星期三晚上,18:30 至 21:30, 每次三个小时地点 :G 楼机房内容第一次 (5.16):Java 并发第二次 (5.23):Java 并行第三次 (6.6):Python 基础编程第四次 (6.27):Python 并发编程

16 附上机整体安排星期三晚上 6 点半开始, 至 9 点半结束

17 4.1 并行算法设计结构编程算法应用

Natural Language Processing, Topic Modeling, Neural Text Generation and Ali Xiaomi

Natural Language Processing, Topic Modeling, Neural Text Generation and Ali Xiaomi 并行计算 :Parallel Computing 结构编程算法应用 3.3 Java 并发与并行程序设计徐悦甡 (Yueshen Xu) ysxu@xidian.edu.cn 软件工程系西安电子科技大学本节提纲 Java 语言基础讨论 Java 并发程序设计 Java 多线程机制 Java 中多线程的创建 Thread 方法途径 Runnable 接口途径 Java 多线程程序举例 Java