-Trace deadlock avec deux consommateurs, deux producteurs et un tampon de taille 1.
+Pseudo-trace deadlock avec deux consommateurs, deux producteurs et un tampon de taille 1.
+-----------------------------------------------------------------------------------------
-Buffer vide -> C1 et C2 sont en attente (suspendus).
- -> P1 rentre en section critique, depose et notifie un thread, mettons P2
-Buffer plein -> P1 se met en attente, P2 a été notifié mais le buffer est plein, donc
- P2 en attente.
- -> donc C1, C2, P1, P2 sont en attente
- et aucune notification ne sera faite pour les réveiller.
+Buffer vide -> C1 et C2 se mettent en attente dans la file (C1, C2).
+ -> P1 rentre en section critique et P2 se met en attente soit (P2, C1, C2).
+ P1 depose et notifie a un thread en attente. Le dernier en attente est P2 donc P2 est notifié.
+Buffer plein -> P2 sort de la file d'attente (C1, C2) et entre en SC, P1 se met en attente (P1, C1, C2).
+ Or le buffer est plein, donc P2 se met en attente dans la file (P2, P1, C1, C2).
+ -> donc C1, C2, P1, P2 sont en attente dans la file (P2, P1, C1, C2)
+ et aucune notification ne sera faite pour les sortir de la file.
-> deadlock.
Solution: faire un notifyAll() en sortie de SC dans le buffer pour s'assurer que un
- thread d'un type différent du type courant sortant du moniteur est notifié
- (Consommateur -> Producteur ou Producteur -> Consommateur) et sort de son attente.
+ thread d'un type différent du type courant sortant du moniteur est également notifié
+ (Consommateur -> Producteur ou Producteur -> Consommateur) et sort de son attente.
+
+N.B. : On suppose dans la mise en attente dans moniteur des threads est une file.
+ Mais même si c'est une autre structure de données, la possibilité de deadlock
+ demeure.
--- /dev/null
+import java.io.*;
+import java.net.*;
+import java.util.*;
+
+public class ClientSimplifie {
+ BufferedReader lecture; // pour le flot d'entrée venant du serveur
+ PrintWriter ecriture; // pour le flot de sortie vers le serveur
+ Socket sock; // le socket client
+
+ public ClientSimplifie() {
+ // établie une connexion au serveur par un appel
+ // à connexionServeur()
+ connexionServeur("localhost", 5000);
+ }
+
+ public ClientSimplifie(String adresseIPServeur, int portServeur) {
+ // établie une connexion au serveur par un appel
+ // à connexionServeur()
+ connexionServeur(adresseIPServeur, portServeur);
+ }
+
+ private void connexionServeur(String adresseIPServeur, int portServeur) {
+ // créer un objet socket lié au socket serveur et l'affecte à sock
+ // puis établie les chaînages de flot nécessaires
+ // pour l'envoi et la reception de messages
+ try {
+ sock = new Socket(adresseIPServeur, portServeur);
+ }
+ catch (IOException e) {}
+ InputStream IStream = null;
+ try {
+ IStream = sock.getInputStream();
+ } catch (IOException e) {}
+ InputStreamReader IMesg = new InputStreamReader(IStream);
+ lecture = new BufferedReader(IMesg);
+
+ OutputStream OStream = null;
+ try {
+ OStream = sock.getOutputStream();
+ }
+ catch (IOException e) {}
+ ecriture = new PrintWriter(OStream);
+ }
+
+ public void sendMsg(String msg) {
+ ecriture.println(msg + "\n");
+ ecriture.flush();
+ }
+
+ public String receiveMsg() {
+ String line = new String();
+ try {
+ //FIXME: read only the line before the ending newline
+ line = lecture.readLine();
+ }
+ catch (IOException e) {}
+ return line;
+ }
+
+ public void closeRWIO() {
+ ecriture.close();
+ try {
+ lecture.close();
+ }
+ catch (IOException e) {}
+ }
+
+} // fin classe ClientSimplifie
--- /dev/null
+import java.io.*;\r
+\r
+\r
+public class Main {\r
+\r
+\r
+ public static void main (String[] args) {\r
+\r
+ ClientSimplifie client = new ClientSimplifie();\r
+\r
+ client.sendMsg("Line 1 Line 2");\r
+ String msg = client.receiveMsg();\r
+ System.out.println(msg);\r
+\r
+ client.closeRWIO();\r
+\r
+ }\r
+\r
+}\r
--- /dev/null
+# define compiler and compiler flag variables
+# define a variable for compiler flags (JFLAGS)
+# define a variable for the compiler (JC)
+# define a variable for the Java Virtual Machine (JVM)
+
+JFLAGS = -g
+JC = javac
+JVM = java
+
+#
+# Clear any default targets for building .class files from .java files; we
+# will provide our own target entry to do this in this makefile.
+# make has a set of default targets for different suffixes (like .c.o)
+# Currently, clearing the default for .java.class is not necessary since
+# make does not have a definition for this target, but later versions of
+# make may, so it doesn't hurt to make sure that we clear any default
+# definitions for these
+#
+
+.SUFFIXES: .java .class
+
+
+#
+# Here is our target entry for creating .class files from .java files
+# This is a target entry that uses the suffix rule syntax:
+# DSTS:
+# rule
+# DSTS (Dependency Suffix Target Suffix)
+# 'TS' is the suffix of the target file, 'DS' is the suffix of the dependency
+# file, and 'rule' is the rule for building a target
+# '$*' is a built-in macro that gets the basename of the current target
+# Remember that there must be a < tab > before the command line ('rule')
+#
+
+.java.class:
+ $(JC) $(JFLAGS) $*.java
+
+
+#
+# CLASSES is a macro consisting of N words (one for each java source file)
+# When a single line is too long, use \<return> to split lines that then will be
+# considered as a single line. For example:
+# NAME = Camilo \
+ Juan
+# is understood as
+# NAME = Camilo Juan
+
+CLASSES = \
+ ClientSimplifie.java \
+ Main.java
+
+#
+# MAIN is a variable with the name of the file containing the main method
+#
+
+MAIN = Main
+
+#
+# the default make target entry
+# for this example it is the target classes
+
+default: classes
+
+
+# Next line is a target dependency line
+# This target entry uses Suffix Replacement within a macro:
+# $(macroname:string1=string2)
+# In the words in the macro named 'macroname' replace 'string1' with 'string2'
+# Below we are replacing the suffix .java of all words in the macro CLASSES
+# with the .class suffix
+#
+
+classes: $(CLASSES:.java=.class)
+
+
+# Next two lines contain a target for running the program
+# Remember the tab in the second line.
+# $(JMV) y $(MAIN) are replaced by their values
+
+run: $(MAIN).class
+ $(JVM) $(MAIN)
+
+# this line is to remove all unneeded files from
+# the directory when we are finished executing(saves space)
+# and "cleans up" the directory of unneeded .class files
+# RM is a predefined macro in make (RM = rm -f)
+#
+
+clean:
+ $(RM) *.class
repositories / TD_SR.git / commitdiff
