From dfde37e482913ab374d6a0927444bd61d9ffaf41 Mon Sep 17 00:00:00 2001 From: Benjamin Date: Tue, 8 Mar 2022 20:48:34 +0100 Subject: [PATCH] =?UTF-8?q?R=C3=A9glage=20blocage=20des=20threads=20des=20?= =?UTF-8?q?SBE=20:=20Les=20SBE=20attendaient=20d'=C3=AAtre=20r=C3=A9veill?= =?UTF-8?q?=C3=A9=20doublement=20pour=20reprendre=20le=20travaille?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/lightcontainer/domains/client/StoreProcessor.java | 2 +- .../lightcontainer/repository/StoreProcessorRepository.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java b/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java index 642cdd8..5af0c65 100644 --- a/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java +++ b/app/src/main/java/lightcontainer/domains/client/StoreProcessor.java @@ -114,6 +114,7 @@ public class StoreProcessor extends Thread implements AutoCloseable { public void executeCommand(ProtocolWriter.ProtocolResult protocolResult) { synchronized (this) { this.protocolResult = protocolResult; + System.out.println("Request wake up"); this.notify(); } } @@ -125,7 +126,6 @@ public class StoreProcessor extends Thread implements AutoCloseable { synchronized (this) { this.protocolResult = null; fileFrontEnd.onStoreAvailable(this, responseCommand); - waitAction(); } } diff --git a/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java b/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java index fd6bd4d..174b0ae 100644 --- a/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java +++ b/app/src/main/java/lightcontainer/repository/StoreProcessorRepository.java @@ -74,6 +74,7 @@ public class StoreProcessorRepository implements AutoCloseable, MulticastSPR { @Override public void assignTask(String stor, Task task) { StoreProcessor handler = findSBE(task); + System.out.println("Find stor : " + handler); handler.executeCommand(task.getCommand()); }