from threading import Thread
import time

def task(name):
    print(f'子線程{name} is running')
    time.sleep(1)
    print(f'子線程{name} is end')
    
# 因?yàn)閯?chuàng)建線程不需要重新開(kāi)辟內(nèi)存空間，所以不用寫(xiě)main，創(chuàng)建線程只是單獨(dú)把啟動(dòng)線程函數(shù)里面的代碼拿出來(lái)用
t = Thread(target=task,args=('小明',))
t.start()
print('主線程結(jié)束')

from threading import Thread
import time

class MyDic(Thread,name):
    def __init__(self,name)
    	super().__init__()
        self.name = name
    
    def run(self):
        print(f'子線程{name} is running')
        time.sleep(1)
        print(f'子線程{name} is end')

       
t = Mydic('小明')
t.start()
print('主進(jìn)程結(jié)束')

'''
學(xué)習(xí)中遇到問(wèn)題沒(méi)人解答？小編創(chuàng)建了一個(gè)Python學(xué)習(xí)交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和PDF電子書(shū)！
'''
from threading import Thread
from multiprocessing import  Process
import time
import os

def task(name):
    print(f'子線程{name} is running')
    time.sleep(1)
    print(f'子線程{name} is end')
    print(f'子線程{name}的pid：{os.getpid()}')


def task1(name):
    print(f'進(jìn)程{name} is running')
    time.sleep(1)
    print(f'進(jìn)程{name} is end')
    print(f'進(jìn)程的{name}pid：{os.getpid()}')


if __name__ == '__main__':
    # part1:在主進(jìn)程下開(kāi)啟多個(gè)線程,每個(gè)線程都跟主進(jìn)程的pid一樣
    t = Thread(target=task, args=('小明',))
    t.start()
    t.join()
    print(f'主線程的pid：{os.getpid()}')

    
    # 開(kāi)多個(gè)進(jìn)程，每一個(gè)進(jìn)程的pid號(hào)都不一樣
    p = Process(target=task1,args=('zhangsan',))
    p1 = Process(target=task1,args=('zhang',))
    p.start()
    p1.start()
    p.join()
    p1.join()
    print(f'主進(jìn)程的pid：{os.getpid()}')

from threading import Thread
from multiprocessing import Process
import time

def task(name):
    print(f'{name} is running')
    time.sleep(2)
    print(f'{name} is end')


if __name__ == '__main__':
    t = Thread(target=task,args=('子線程',))
    p = Process(target=task,args=('子進(jìn)程',))
    t.start()
    # p.start()
    print('主')

子線程 is running

主

子線程 is end

主

子進(jìn)程 is running

子進(jìn)程 is end

from threading  import Thread
from multiprocessing import  Process
import time,os

x = 100
def task():
    global x
    x = 50 # 此時(shí)線程是在拿全局的x的值
    print(os.getpid()) # 因?yàn)殚_(kāi)啟線程是不需要操作系統(tǒng)給線程分配內(nèi)存空間的，所以線程用的是它當(dāng)前所在的進(jìn)程的進(jìn)程號(hào)


if __name__ == '__main__':
    # 線程
    t = Thread(target=task)
    t.start()
    time.sleep(2)
    print(x) # 50，這里說(shuō)明線程他是共享他所在進(jìn)程下的所有資源，對(duì)資源進(jìn)行一系列的操作
    print(os.getpid())

    # 進(jìn)程
   # p = Process(target=task)
   # p.start() 
   # print(x) # 這里的x還是主進(jìn)程的x 100

from threading import Thread,currentThread,enumerate,activeCount
import time

def task():
    print('子線程 start')
    time.sleep(2)
    print('子線程 end')
    print(enumerate())# 返回一個(gè)包含正在運(yùn)行的線程的list。正在運(yùn)行指線程啟動(dòng)后、結(jié)束前，不包括啟動(dòng)前和終止后的線程。
    print(currentThread(),'子線程') # 返回當(dāng)前的線程變量
    print(activeCount())

if __name__ == '__main__':
   t1 = Thread(target=task)
   t2 = Thread(target=task)
   t1.start()
   t2.start()
   t2.setName('小明')
   print(t2.getName()) # 得到t2的線程名字，是我們?cè)O(shè)置好的小明
   print(t1.getName()) # 得到t1的線程名子 Thread-1
   print(t1.is_alive()) # True

'''
學(xué)習(xí)中遇到問(wèn)題沒(méi)人解答？小編創(chuàng)建了一個(gè)Python學(xué)習(xí)交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和PDF電子書(shū)！
'''
from threading import Thread
import time
def task():
    print('子線程 start')
    time.sleep(2)
    print('子線程 end')

t = Thread(target=task)
t.start()
t.join() # 等待子線程運(yùn)行結(jié)束
print('主線程')

import socket
from threading import Thread

socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
socket.bind(('192.168.11.78',8004))
socket.listen(5)

def action(conn,addr):
    while True:
        try:

            msg = (conn.recv(1024)).decode('utf8').upper()
            print(f'客戶端{(lán)addr}發(fā)送的數(shù)據(jù)為：{msg.lower()}')
            print(f'向客戶端{(lán)addr}發(fā)送數(shù)據(jù)為',msg)
            conn.send(msg.encode('utf8'))
        except:
            break


if __name__ == '__main__':
    print('等待客戶端連接:')
    while True:
        try:
            conn,addr = socket.accept()
            print(f'客戶端已連接{addr}')
            t = Thread(target=action,args=(conn,addr))
            t.start()
        except:
            print(f'客戶端{(lán)addr}斷開(kāi)連接 ??！')
            break

import  socket

client = socket.socket()
client.connect(('192.168.11.78',8004))

while True:
    msg = input('輸入：')
    if msg == 'q':
        break
    client.send(msg.encode('utf8'))
    flag = client.recv(1024)
    print('接收服務(wù)端的數(shù)據(jù)為：',flag.decode('utf8'))