import threading
def worker(name):print("thread %s is running" % name)
worker = threading.Thread(target=worker, args=('worker',))
worker.start()
worker.join()

import threading
import timeclass MyThread(threading.Thread):def __init__(self, delay):super(MyThread, self).__init__()self.delay = delaydef run(self):while True:print("sleep %ds" % self.delay)time.sleep(self.delay)delays = [2, 4, 6]
threads = []
for delay in delays:threads.append(MyThread(delay))
for t in threads:t.start()
for t in threads:t.join()

import threading
import timeclass myThread (threading.Thread):def __init__(self, threadID, name, counter):#super(myThread, self).__init__()threading.Thread.__init__(self)self.threadID = threadIDself.name = nameself.counter = counterdef run(self):print ("开启线程： " + self.name)# 获取锁，用于线程同步threadLock.acquire()print_time(self.name, self.counter, 3)# 释放锁，开启下一个线程threadLock.release()def print_time(threadName, delay, counter):while counter:time.sleep(delay)print ("%s: %s" % (threadName, time.ctime(time.time())))counter -= 1threadLock = threading.Lock()
threads = []# 创建新线程
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)# 开启新线程
thread1.start()
thread2.start()# 添加线程到线程列表
threads.append(thread1)
threads.append(thread2)# 等待所有线程完成
for t in threads:t.join()
print ("退出主线程")

def _async_raise(tid, exctype):"""Raises an exception in the threads with id tid"""if not inspect.isclass(exctype):raise TypeError("Only types can be raised (not instances)")res = ctypes.pythonapi.PyThreadState_SetAsyncExc(ctypes.c_long(tid), ctypes.py_object(exctype))if res == 0:raise ValueError("invalid thread id")elif res != 1:# """if it returns a number greater than one, you're in trouble,# and you should call it again with exc=NULL to revert the effect"""ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, None)raise SystemError("PyThreadState_SetAsyncExc failed")def stop_thread(thread):_async_raise(thread.ident, SystemExit)

class MyThread(threading.Thread):"""Thread class with a stop() method. The thread itself has to checkregularly for the stopped() condition."""def __init__(self, *args, **kwargs):super(MyThread, self).__init__(*args, **kwargs)self._stop_event = threading.Event()def stop(self):self._stop_event.set()def stopped(self):return self._stop_event.is_set()def run(self):while True:#做任务print("sleep 1s")time.sleep(1)if self.stopped():# 做一些必要的收尾工作break

import requests#json_data = {"cancel": "yes"}
json_data = {"nums": 2, "cancel": "no"}r = requests.post("http://127.0.0.1:5000/access_api", json=json_data)
print(r.text, type(r.text))

import json
from flask import Flask, request
from test_API.test_process import MyThreadapp = Flask(__name__)
threads = []@app.route('/')
def hello_world():return 'hello world'@app.route('/access_api', methods=['POST'])
def access_api():#print(request.headers)global threads#声明变量类型为全局变量state = Nonetry:print(threads)cancel = request.json['cancel']if cancel == "no":print("for testing of performing")nums = request.json['nums']for i in range(nums):threads.append(MyThread(i+1))for t in threads:t.start()elif cancel == "yes":print('for testing of canceling')for t in threads:t.stop()#MyThread.stop()threads = []state = 'Successful'except:state = 'Failed'finally:return stateif __name__ == '__main__':app.run(host='0.0.0.0', port=5000, debug=True)#本地访问ip为127.0.0.1#局域网其它电脑访问：提供本电脑的ip地址

import json
import time
import threadingclass MyThread(threading.Thread):"""Thread class with a stop() method. The thread itself has to checkregularly for the stopped() condition."""def __init__(self, delay):super(MyThread, self).__init__()self._stop_event = threading.Event()self.delay = delaydef stop(self):self._stop_event.set()def stopped(self):return self._stop_event.is_set()def run(self):print("begin run the child thread")while True:print("sleep %ds" % self.delay)time.sleep(self.delay)if self.stopped():# 做一些必要的收尾工作break