セマフォを使用したn個のプロセスバリアの実装
-
27-10-2019 - |
質問
私は現在、以前の反復でOS試験のための訓練を受けており、私はこれに遭遇しました:
"Nプロセス障壁"を実装します。 各プロセスが それらのグループのいくつかで、待機します のために、それぞれの実行中のポイント 彼らに到達するための他のプロセス 与えられたポイント。
あなたは次のものを持っています 利用可能なops:
init(sem,value), wait(sem) and signal(sem)
Nは任意の数である。指定された数のプロセスで機能するようにすることはできますが、任意の数では機能しません。
何か考えは?擬似コードで返信するのは大丈夫ですが、これは割り当てではなく、単なる個人的な研究です。
解決
これはよく提示されています セマフォの小さな本.
n = the number of threads
count = 0
mutex = Semaphore(1)
barrier = Semaphore(0)
mutex.wait()
count = count + 1
mutex.signal()
if count == n: barrier.signal() # unblock ONE thread
barrier.wait()
barrier.signal() # once we are unblocked, it's our duty to unblock the next thread
他のヒント
N個のセマフォを使う。よくわからない..
semaphore barr[N]
semaphore excl=1
int count=0
int i=1
while (i<=N)
barr[i]=0 #initialization
i=i+1
# use, each thread (tid)
wait(excl)
count=count+1
if (count==N)
int j=1
while (j<=N)
signal(barr[j])
j=j+1
count=0
signal(excl)
wait(barr[tid])
バリアセマフォは2つしかありませんが、わかりません。..
semaphore barr[0..1] # two semaphores: barr[0] and barr[1]
semaphore excl=1
int count=0
int whichOne=0 # select semaphore to avoid race conditions
barr[0]=0 #initialization
barr[1]=0
# sample use
int current #local for each thread
wait(excl)
current=whichOne
count=count+1
if (count==N)
int j=1
while (j<=N)
signal(barr[current])
j=j+1
count=0
whichOne=1-whichOne # swap barrier to avoid race conditions
signal(excl)
wait(barr[current])
所属していません StackOverflow