且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

GCD-关键部分/互斥体

更新时间:2023-11-13 22:36:58

好的,这是可行的示例(贷方@KenThomases ...)

ok, here is the working example (credit goes to @KenThomases ...)

import Dispatch

let semaphore = DispatchSemaphore(value: 1)
let printQueue = DispatchQueue(label: "print queue")
let group = DispatchGroup()

func longRuningTask(i: Int) {

    printQueue.async(group: group) {
        print(i,"GREEN semaphore")
    }
    usleep(1000)               // cca 1 milisecond
    printQueue.async(group: group) {
        print(i,"job done")
    }
}

func shortRuningTask(i: Int) {
    group.enter()
    guard semaphore.wait(timeout: .now() + 0.001) == .success else { // wait for cca 1 milisecond from now
        printQueue.async(group: group) {
            print(i,"RED semaphore, job not done")
        }
        group.leave()
        return
    }
    longRuningTask(i: i)
    semaphore.signal()
    group.leave()
}

printQueue.async(group: group) {
    print("running")
}

DispatchQueue.concurrentPerform(iterations: 10, execute: shortRuningTask )
group.wait()
print("all done")

及其打印输出

running
0 GREEN semaphore
2 RED semaphore, job not done
1 RED semaphore, job not done
3 RED semaphore, job not done
0 job done
4 GREEN semaphore
5 RED semaphore, job not done
6 RED semaphore, job not done
7 RED semaphore, job not done
4 job done
8 GREEN semaphore
9 RED semaphore, job not done
8 job done
all done
Program ended with exit code: 0