标签: 多线程

1. synchronized线程锁

1.1. 使用


 class  data{
     private Integer d=0;
    public  void d1(){
        synchronized (d) {
            d=1;
            System.out.println(d);
        }
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

    }
    public  void d2() {
        d=2;
        System.out.println(d);
    }
}
public class demo5 {


    public static void main(String[] args) {
        data d=new data();
        new Thread(()->{
            d.d1();
        },"a").start();
        new Thread(()->{
            d.d2();
        },"b").start();
    }
}

刘欢原创2022/7/27大约 5 分钟

多线程

多核并行等待

#! coding=utf-8
from multiprocessing import cpu_count
from concurrent.futures import ProcessPoolExecutor ,wait
print(cpu_count())
def play(pari):
    time.sleep(2)
    print(pari)
    return {'url':'url'}
def doneFunc(obj):
'''
回调函数
'''
    res=obj.result();
    # 获取返回的内容
    print(res)
    print('done')
import time
if __name__ == '__main__':
    start = time.time()
    # result = ProcessPoolExecutor().map(play, range(1,100))
    futures = {}
    with ProcessPoolExecutor() as p:
        for i in range(30):
            job=p.submit(play,i).add_done_callback(doneFunc)
            futures[job]=i
    # 等待执行
    # wait(futures)
    p.shutdown(True)
    end = time.time()

    print("耗时:", end - start)
    print(123)

刘欢原创2022/6/14大约 4 分钟

多线程

工厂模式

# -*- coding: UTF-8 -*-
class demo1(object):
    def p(self):
        print(1)
class demo2(object):
    pass
class demo3(object):
    pass
class demo(object):
    def create(self,type:str):
        if type == "1":
            return demo1()
        elif type == "2":
            return demo2()
        else:
            return demo3()

if __name__ == '__main__':
    d=demo()
    c=d.create("1")
    c.p()

刘欢原创2022/6/14小于 1 分钟