补全：用信号量当信号

👁️ 4 人浏览 💬 0 人评论 ❤️ 添加收藏

本节的东西：

Gate(n)   最多 n 个同时在里面：Semaphore(n)；顺便用一把小锁维护 inside / peak（峰值）
run_gate(n, workers, hold)   workers 条线程各进一次 Gate 待 hold 秒，交回峰值

补全 handoff()：Semaphore(0) 开始是关的；线程乙先 acquire（等）；主线程睡 0.05 秒后把 "货" 放进 box 再 release；乙醒来取货。交回 (乙拿到的东西, 乙是否在 release 之前就取到了)。

提交你的答案

请登录后提交答案。

去登录

← 补全：限流的下载池补全：连接池 →

更多题目

代码编辑器

语言： Ctrl + Enter 运行

import threading
import time

class Counter:
    def __init__(self):
        self.n = 0

def inc(self):
        tmp = self.n
        time.sleep(0.001)
        self.n = tmp + 1

class SafeCounter(Counter):
    def __init__(self):
        super().__init__()
        self.lock = threading.Lock()

def inc(self):
        with self.lock:
            tmp = self.n
            time.sleep(0.001)
            self.n = tmp + 1

def hammer(counter, workers=2, times=30):
    def job():
        for _ in range(times):
            counter.inc()
    ts = [threading.Thread(target=job) for _ in range(workers)]
    for t in ts:
        t.start()
    for t in ts:
        t.join()
    return counter.n

def probe(lock):
    """这把锁现在能不能立刻拿到？能就拿了再放回去，交回 True；拿不到交回 False。"""
    if lock.acquire(blocking=False):
        lock.release()
        return True
    return False

class Guard:
    """手写的 with 替身：进就 acquire，出就 release——不管是正常出还是异常出。"""
    def __init__(self, lock):
        self.lock = lock

def __enter__(self):
        self.lock.acquire()
        return self

def __exit__(self, exc_type, exc, tb):
        self.lock.release()
        return False

def handoff():
    sem = threading.Semaphore(0)
    box = []
    got = []
    early = []

def b():
        # TODO: sem.acquire() 然后 got.append(box[0])
        pass

t = threading.Thread(target=b)
    t.start()
    time.sleep(0.05)
    early.append(len(got))
    box.append("货")
    # TODO: sem.release()
    t.join()
    return got[0], early[0] > 0

print("/".join(str(x) for x in handoff()))

本次输入：

输出：

👩‍🏫

💬 题目评论

补全：用信号量当信号

更多题目

全部评论