### Mutual Exclusion

```Chapter 5
Concurrency:
Mutual Exclusion and
Synchronization
CS 345
Stalling’s Chapter
#
Project
1: Computer System Overview
2: Operating System Overview
4
P1: Shell
3: Process Description and Control
4
5: Concurrency: ME and Synchronization
6
P3: Jurassic Park
7: Memory Management
8: Virtual memory
6
P4: Virtual Memory
9: Uniprocessor Scheduling
10: Multiprocessor and Real-Time Scheduling
6
P5: Scheduling
11: I/O Management and Disk Scheduling
12: File Management
8
P6: FAT
Student Presentations
6
BYU CS 345
Mutual Exclusion
2
Project 2 Assignment
Step 1: Priority Queue

Create a priority queue



typedef int TID;
typedel int Priority;
typedef int* PQueue;
// priority queue
PQueue rq;
rq[0] = 0;
Queue functions



q
tid

int
BYU CS 345
Priority/TID
Priority/TID
Priority/TID
Priority/TID
# of entries
rq[5]
int enQ(PQueue q, TID tid, Priority p);
int deQ(PQueue q, TID tid);


# | pr1/tid1 | pr2/tid2 | …
>=0
find and delete tid from q
-1
return highest priority tid
tid
(if found and deleted from q)
-1
rq[4]
10 / 3
rq[3]
5/2
rq[2]
5/0
rq[1]
2/1
rq[0]
4
3
State Change in C






The setjmp/longjmp set of macros implemented in the C
provide the perfect platform to perform complex flow-control.
The setjmp function saves the state of a program. The state
of a program, to be precise, are the values of sp (stack
pointer), fp (frame pointer), pc (program counter).
A program state is completely defined by this set of registers
and the contents of the memory, which includes the stack.
Executing a setjmp returns 0 after saving the stack
environment.
If setjmp returns as a result of a longjmp call, the value is the
argument of the longjmp (0 is never returned).
A call to longjmp restores the saved environment and returns
control to the point just after the corresponding setjmp call.
BYU CS 345
4
setjmp/longjmp
setjmp / longjmp


#include <setjmp.h>
jmp_buf struct


setjmp(jmp_buf env);



stack pointer (sp), frame pointer (fp), and program
counter (pc).
saves the program state (sp, fp, pc) in env so that
longjmp() can restore them later.
returns 0 value.
longjmp(jmp_buf env, int val);


BYU CS 345
resets the registers to the values saved in env.
longjmp() returns as if you have just called the
setjmp() call that saved env with non-zero value.
5
setjmp/longjmp
jmp_buf k_context;
int tid;
{
while (1)
{
if(!setjmp(tcb[tid].context))
longjmp(k_context,2);
// execute function
}
}
BYU CS 345
for (tid = 0; tid < 4; tid++)
{
if (setjmp(k_context) == 0)
{
temp = (int*)tcb[tid].stackEnd;
SET_STACK(temp);
if (setjmp(tcb[tid].context) == 0)
{
longjmp(k_context, 1);
}
}
}
while (1)
{
tid = scheduler();
if (setjmp(k_context) == 0)
{
longjmp(tcb[tid].context, 3);
}
}
6
setjmp/longjmp
BYU CS 345
7
Project 2 Assignment





PQueue rq;
rq[0] = 0;
enQ(rq, tid, tcb[tid].priority);
Change scheduler() to deQueue and then

if ((nextTask = deQ(rq, -1)) >= 0)
{
}
BYU CS 345

Priority/TID
Priority/TID
Priority/TID
Priority/TID
# of entries
rq[5]
rq[4]
10 / 3
rq[3]
5/2
rq[2]
5/0
rq[1]
2/1
rq[0]
4
8
2-State Scheduler
New
Queue
dispatch()
Running
Exit
BYU CS 345
9
Chapter 5 Learning Objectives





Discuss basic concepts related to concurrency, such as
race conditions, OS concerns, and mutual exclusion
requirements.
Understand hardware approaches to supporting mutual
exclusion.
Define and explain semaphores.
Define and explain monitors.
Explain




BYU CS 345
Producer/Consumer
Bounded buffer
Classical synchronization problems
Mutual Exclusion
10
Mutual Exclusion
Review…


The OS must keep track of active processes.
The OS must allocate and deallocate resources.






Processor time
Memory
Files
I/O devices
The OS must protect the data and physical
resources.
The results of a process must be independent of
the speed of execution relative to the speed of
other concurrent processes.
BYU CS 345
Mutual Exclusion
11
Mutual Exclusion
Resource Allocation

Mutual Exclusion






Critical resource – a single nonsharable resource.
Critical section – portion of the program that
accesses a critical resource.
Each process owns a resource that the other is
waiting for.
Two processes are waiting for communication from
the other.
Starvation

BYU CS 345
though there is no deadlock situation.
Mutual Exclusion
12
Semaphores
Semaphores

SEM_SIGNAL


SEM_WAIT


Consumer
SEM_TRYLOCK


Producer
Conditional consumer
Semaphores used for:



Synchronization
Resource
Mutual Exclusion
BYU CS 345
Mutual Exclusion
13
Semaphores
Consider…
P0:
P1:
wait(S);
wait(Q);
.
.
.
signal(S);
signal(Q);
wait(Q);
wait(S);
.
.
.
signal(Q);
signal(S);
Is there anything wrong here?
BYU CS 345
Mutual Exclusion
14
Producer/Consumer
The Producer-Consumer Problem
Producer
Consumer
repeat
…
produce an item in nextp
…
while (counter == n);
buffer[in] = nextp
in = (in + 1) mod n
counter = counter + 1
repeat
…
while (counter == 0);
nextc = buffer[out]
out = (out + 1) mod n
counter = counter - 1
…
consume the item in nextc
…
until false
until false
Is there anything wrong here?
BYU CS 345
Mutual Exclusion
15
Semaphores
Autonomy

Critical


Uniprocessor



Semaphore operations
must be atomic
simply inhibit interrupts
(normal user can’t)
Use TestAndSet to
create a mutex in the
calls
Multiprocessor


semWait(Semaphore s)
{
while(TestAndSet(&lock));
s.value--;
if (s.value < 0)
{
*lock = FALSE;
block;
}
else *lock = FALSE;
}
hardware must provide
special support, or
use software solutions
BYU CS 345
Mutual Exclusion
16
Semaphores
Semaphores

Binary Semaphore

2 states



0 = nothing produced, maybe tasks in queue
1 = something produced, no tasks in queue
Counting Semaphore

Resource counter



BYU CS 345
0 = nothing produced, nothing in queue
-n = nothing produced, n tasks queued
+n = n items produced, no tasks in queue
Mutual Exclusion
17
Semaphores
SEM_SIGNAL - Producer
void semSignalBinary(Semaphore* semaphore)
{
semaphore->state = 1;
if (tid = deQ(semaphore->queue) < 0) return;
semaphore->state = 0;
enQ(rq, tid);
return;
} // end semSignalBinary
// signal binary semaphore
void semSignalCounting(Semaphore* semaphore)
{
if (++semaphore->state > 0) return;
tid = deQ(semaphore->queue);
enQ(rq, tid);
return;
} // end semSignalCounting
// signal counting semaphore
BYU CS 345
Mutual Exclusion
// produce (signal) binary semaphore
// dequeue blocked task (if any)
// consume (clear) semaphore
// return if nothing in queue
18
Semaphores
SEM_WAIT - Consumer
void semWaitBinary(Semaphore* semaphore)
{
if (semaphore->state == 1)
{
semaphore->state = 0;
return;
}
// wait binary semaphore
// signaled?
// y, consume semaphore
// return w/no block
// resource not available, block task
// change task state to blocked
return;
// returning from blocked state
} // end semWaitBinary
BYU CS 345
Mutual Exclusion
19
Semaphores
SEM_WAIT - Consumer
void semWaitCounting(Semaphore* semaphore)
{
semaphore->state--;
if (semaphore->state >= 0) return;
// wait counting semaphore
// consume
// if available, return
// resource not available, block task
// change task state to blocked
return;
// returning from blocked state
} // end semWaitCounting
BYU CS 345
Mutual Exclusion
20
Project 2 Assignment
Step 3: 5-State Scheduling

Add priority queue to semaphore struct



// semaphore
// semaphore name (malloc)
// state (count)
// type (binary/counting)
// tid of creator
// blocked queue
Malloc semaphore queue in createSemaphore


typedef struct semaphore
{
char* name;
int state;
int type;
PQueue q;
} Semaphore;
semaphore->q[0] = 0;
// init queue
enQueue in semaphore queue
semSignal: deQueue task from blocked queue and
BYU CS 345
21
5-State Scheduler
#define
#define
#define
#define
New
SWAP
SEM_WAIT(s)
SEM_SIGNAL(s)
SEM_TRYLOCK(s)
semWait(s);
semSignal(s);
semTryLock(s);
Queue
dispatch()
Running
Exit
Blocked
Queues
BYU CS 345
22
Scheduling
Scheduler / Dispatcher
Executing
SWAP
SEM_SIGNAL
SEM_SIGNAL
SEM_SIGNAL
Semaphore Priority Queue
Semaphore Priority Queue
Semaphore Priority Queue
SEM_WAIT
SEM_WAIT
SEM_WAIT
…
BYU CS 345
23
Project 2 Assignment
Step 4a: Counting Semaphore




Add a 10 second timer (tics10sec) counting semaphore
to the polling routine (os345interrupts.c).




os345semaphores.c: semSignal, semWait, semTryLock
Replace goto temp;
Call the C function time(time_t *timer).
semSignal the tics10sec semaphore every 10 seconds.
Create a reentrant high priority timing task that


blocks (SEM_WAIT) on the 10 second timer semaphore
(tics10sec).
when activated, outputs a message with the current task
number and time and then blocks again.
BYU CS 345
24
Project 2 Assignment

Modify the list tasks command to




Display all tasks in all system queues in execution/priority order
If the task is blocked, list the reason for the block.
Use the project2 command to schedule timer tasks 1



a round robin order. (Round Robin)
The “ImAlive” tasks will periodically say hello. (Blocking)
The high priority “Signal” tasks should respond immediately
when semaphore signaled. (Priority)
BYU CS 345
25
Project 2 Assignment
Step 4c: Verification
Demo

#
Priority
Time slice
Blocking Semaphore
0
CLI w/pseudo-input interrupts
5
1
1-9
TenSeconds
10
1
tics10sec
10
20
1
11
20
1
12
ImAlive
1
1
None
13
ImAlive
1
1
None
BYU CS 345
26
State = { NEW, READY, RUNNING, BLOCKED, EXIT }
Priority = { LOW, MED, HIGH, VERY_HIGH, HIGHEST }
typedef struct
{
char* name;
int state;
int priority;
int argc;
char** argv;
int signal;
// void (*sigContHandler)(void);
void (*sigIntHandler)(void);
// void (*sigKillHandler)(void);
Pending semaphore when blocked.
// void (*sigTermHandler)(void);
// void (*sigTstpHandler)(void);
TID parent;
int RPT;
// task root page table (P4)
int cdir;
Semaphore *event;
void* stack;
jmp_buf context;
} TCB;
BYU CS 345
27
Bounded Buffer
Bounded Buffer Solution
Shared semaphore: empty = n, full = 0, mutex = 1;
repeat
produce an item in nextp
repeat
wait(full);
wait(mutex);
wait(empty);
wait(mutex);
remove an item from buffer
place it in nextc
signal(mutex);
signal(empty);
signal(mutex);
signal(full);
until false
BYU CS 345
consume the item in nextc
until false
Mutual Exclusion
28
Message Passing
Shared Memory






Single atomic variables (semaphores,
modes)
Memory mapping (data structures,
messages)
Test-and-set (atomic instructions)
Fast – do not require data movement
(reference)
Ported memory
Multi-processor systems
BYU CS 345
Mutual Exclusion
29
Synchronization

Classical Synchronization Problems
Barbershop
Dining philosophers
Current System Implementations
Delta Clock
BYU CS 345
Mutual Exclusion
30

Data object is shared (file, memory, registers)



Conditions needing to be satisfied:





many processes that only write data (writers)
many can read at the same time (patron of library)
only one writer at a time (librarian)
no one allowed to read while someone is writing
Different from producer/consumer (general case
with mutual exclusion of critical section) –
possible for more efficient solution if only writers
Solutions result in reader or writer priority
BYU CS 345
Mutual Exclusion
31
Semaphore rmutex=1, wmutex = 1;
Only one writer
at a time
while(true)
{ wait(wmutex);
<write to the data object>
signal(wmutex);
};
while(true)
{
makes sure no one
can write
wait(rmutex);
signal(rmutex);
Last one out allows
writing again
wait(rmutex);
signal(rmutex);
(subject to starvation)
More than one
};
BYU CS 345
Mutual Exclusion
32
Semaphore outerQ, rsem, rmutex, wmutex, wsem = 1;
while(true)
while(true)
{ wait(outerQ);
{ wait(wmutex);
queue here allowing
wait(rsem);
writecnt++;
writers to jump
if (writecnt == 1)
wait(rsem);
signal(wmutex);
Disable
wait(wsem);
wait(wsem);
writers
signal(rmutex);
Wait here until
signal(rsem);
WRITE
signal(outerQ);
signal(wsem);
Once a writer wants to
wait(wmutex);
writecnt--;
allowed
wait(rmutex);
if (writecnt == 0)
signal(rsem);
signal(wmutex);
signal(wsem);
};
Last writer out
signal(rmutex);
allows writers
};
BYU CS 345
Mutual Exclusion
33
Barbershop
Barbershop Problem

3 barbers, each with a barber chair



Sofa can hold 4 customers
Maximum of 20 in shop


Cashier
Entrance
Customers wait outside if necessary
Standing
room area
Exit
Sofa
When a chair is empty:



Barber chairs
Haircuts vary in time
Customer sitting longest on sofa is served
Customer standing the longest sits down
After haircut, customer pays cashier at cash
register

Algorithm has a separate cashier, but often barbers
also take payment
BYU CS 345
Mutual Exclusion
34
Barbershop
Fair Barbershop
procedure customer;
var custnr: integer;
begin
wait ( max_capacity );
/* enter_shop */
wait( mutex1 );
count := count + 1;
custnr := count;
signal( mutex1 );
wait( sofa );
/* sit on sofa */
wait( barber_chair );
/* get up from sofa */
signal( sofa );
/* sit in barber chair */
wait( mutex2 );
enqueue1( custnr );
signal( mutex2 );
wait( finished[custnr] );
/* leave barber chair */
signal( leave_b_chair );
/* pay */
signal( payment );
wait( receipt );
/* exit shop */
signal( max_capacity );
end;
BYU CS 345
procedure barber;
var b_cust: integer
begin
repeat
wait( mutex2 );
dequeue1( b_cust );
signal( mutex2 );
wait( coord );
/* cut hair */
signal( coord );
signal( finished[b_cust] );
wait( leave_b_chair );
signal( barber_chair );
forever
end;
program
var
procedure cashier;
begin
repeat
wait( payment );
wait( coord );
/* accept payment */
signal( coord );
signal( receipt );
forever
end;
barbershop2;
max_capacity: semaphore (:=20);
sofa: semaphore (:=4);
barber_chair, coord: semaphore (:=3);
mutex1, mutex2: semaphore (:=1);
cust_ready, leave_b_chair, payment, receipt: semaphore (:=0)
finished: array [1..50] of semaphore (:=0);
count: integer;
Mutual Exclusion
35
Dining Philosophers
The Dining Philosophers Problem





5 philosophers who only
eat and think.
Each need to use 2 forks
for eating.
There are only 5 forks.
Classical synchronization
problem.
Illustrates the difficulty of
allocating resources
among process without
BYU CS 345
Mutual Exclusion
36
Dining Philosophers
Solution??
Process Pi:
repeat
think;
wait(forks[i]);
wait(forks[(i+1)%5]);
eat;
signal(forks[(i+1)%5]);
signal(forks[i]);
forever


Each philosopher is a
process.
One semaphore per
fork:


forks: array[0..4] of
semaphores
Initialization:
forks[i].count:=1 for
i:=0..4
• Deadlock if each philosopher starts by picking left fork!
BYU CS 345
Mutual Exclusion
37
Dining Philosophers
Another Solution




philosophers at a time
that tries to eat
Then 1 philosopher can
always eat when the
other 3 are holding 1
fork
Introduce semaphore T
that limits to 4 the
number of philosophers
“sitting at the table”
Initialize: T.count:=4
BYU CS 345
Process Pi:
repeat
think;
wait(T);
wait(forks[i]);
wait(forks[(i+1)%5]);
eat;
signal(forks[(i+1)%5]);
signal(forks[i]);
signal(T);
forever
Mutual Exclusion
38
Dining Philosophers
Other Solutions…



Put fork down if 2nd fork busy



Only let 4 of the philosophers into the room at once
May have 4 philosophers in room, but only 1 can eat
Left-Handed Philosophers (asymmetric solution)



“livelock” if philosophers stay synchronized
Room Attendant


Equivalent to increasing resources
Grab forks in the other order (right fork, then left fork)
Any mix will avoid deadlock (linear ordering on forks)
A philosopher may only pick up forks in pairs.

must allocate all resources at once
BYU CS 345
Mutual Exclusion
39
Message Passing
Message Passing

A general method used for interprocess
communication (IPC)




Another means to provide process
synchronization and mutual exclusion
We have at least two primitives:



for processes inside the same computer
for processes in a distributed system
send(destination, message) or post(destination,
message)
May or may not be blocking
BYU CS 345
Mutual Exclusion
40
Message Passing
Synchronization

For the sender: it is more natural not to be
blocked





can send several messages to multiple destinations
sender usually expects acknowledgment of message
PostMessage() is asynchronous – returns immediately
SendMessage() is synchronous –block until message
delivered and processed
For the receiver: it is more natural to be blocked


the receiver usually needs the info before proceeding
but could be blocked indefinitely if sender process fails
BYU CS 345
Mutual Exclusion
41
Message Passing




when a specific process identifier is used
for source/destination
but it might be impossible to specify the
source ahead of time (ex: a print server)


messages are sent to a shared mailbox
which consists of a queue of messages
senders place messages in the mailbox,
BYU CS 345
Mutual Exclusion
42
Message Passing
Mailboxes and Ports

A mailbox can be private


A mailbox can be shared
among several senders and


OS may then allow the use of
message types (for selection)
Port: a mailbox associated
senders

used for client/server
server
BYU CS 345
Mutual Exclusion
43
Message Passing
Port/Mailbox Ownership




A port is usually owned and created by the
receiving process
The port is destroyed when the receiver
terminates
The OS creates a mailbox on behalf of a
process (which becomes the owner)
The mailbox is destroyed at the owner’s
request or when the owner terminates
BYU CS 345
Mutual Exclusion
44
Monitor
Monitor

A software module
containing:




one or more procedures
an initialization sequence
local data variables
Characteristics:



local variables accessible
only by monitor’s procedures
a process enters the monitor
by invoking one of its
procedures
only one process can be in
the monitor at any one time
BYU CS 345
Mutual Exclusion
45
Monitor
Monitor for the P/C problem
Monitor boundedbuffer:
buffer: array[0..k-1] of items;
nextin:=0, nextout:=0, count:=0: integer;
notfull, notempty: condition;
Produce(v):
if (count = k) cwait(notfull);
buffer[nextin] := v;
nextin := nextin+1 mod k;
count++;
csignal(notempty);
Consume(v):
if (count = 0) cwait(notempty);
v := buffer[nextout];
nextout := nextout+1 mod k;
count--;
csignal(notfull);
BYU CS 345
Mutual Exclusion
46
Conclusion
Conclusion


Semaphores are a powerful tool for enforcing
mutual exclusion and to coordinate processes
But wait(S) and signal(S) are scattered among
several processes.


difficult to understand their effects
Usage must be correct in all the processes

One bad (or malicious) process can fail the entire
collection of processes
BYU CS 345
Mutual Exclusion
47
BYU CS 345
Mutual Exclusion
48
```