小小影视官网 广州亚马逊服装工厂调研:大型供应链企业的实力分层与选厂逻辑
发布日期:2026-04-25 18:13 点击次数:146

比如点赞是一个stuck类型的结构体,含有 执行方法
go worker pool start启动多个go协程,每个协程都监听chain,每个协程函数用一个退出ch,监听到退出ch有东西了就退出,执行的时候外部外部把task submit到chain, workerpool就自己去抢数据
mutex 锁,同一个时间只允许一个线程执行lock中间的内容,其他会被挡住。
worker pool is start 变量要加lock,99精品久久99久久久久防止外部多协程同时启动worker pool。
分布式锁:用redis.setnx 多个积机器的协程抢锁,抢到了就加锁执行,也给锁生成一个字符串,((丰满老女人))伦理删除锁也使用原子操作,判断value和执行删除之间存在时间差。协程a决定执行删除卡住了,然后协程b进来加了锁,协程a就错删了b的锁
watchdog 增加了一个时间channel,间隔一段时间就给channel发送一个信号,表示cpu还在运作。给超时的执行extend.
自己实现一个高并发点赞+分布式锁的功能,点赞这个task设计好,service获取一个task, 就丢到线程池执行小小影视官网,创建分布式锁对象,aquire, release
发布于:广东省
