diff --git a/opencl/test/unit_test/mt_tests/direct_submission/direct_submission_controller_tests_mt.cpp b/opencl/test/unit_test/mt_tests/direct_submission/direct_submission_controller_tests_mt.cpp
index 26152814fb..ecb86b92fb 100644
--- a/opencl/test/unit_test/mt_tests/direct_submission/direct_submission_controller_tests_mt.cpp
+++ b/opencl/test/unit_test/mt_tests/direct_submission/direct_submission_controller_tests_mt.cpp
@@ -16,7 +16,7 @@
 
 namespace NEO {
 
-TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWhenNewSubmissionThenDirectSubmissionsAreChecked) {
+TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWhenTimeoutThenDirectSubmissionsAreChecked) {
     MockExecutionEnvironment executionEnvironment;
     executionEnvironment.prepareRootDeviceEnvironments(1);
     executionEnvironment.initializeMemoryManager();
@@ -28,56 +28,29 @@ TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWhenNewSu
                                                            EngineDescriptorHelper::getDefaultDescriptor({aub_stream::ENGINE_CCS, EngineUsage::regular},
                                                                                                         PreemptionMode::ThreadGroup, deviceBitfield)));
     csr.setupContext(*osContext.get());
+    csr.initializeTagAllocation();
+    *csr.tagAddress = 9u;
+    csr.taskCount.store(9u);
 
     DirectSubmissionControllerMock controller;
     executionEnvironment.directSubmissionController.reset(&controller);
     controller.timeoutElapsedReturnValue.store(TimeoutElapsedMode::fullyElapsed);
-    controller.registerDirectSubmission(&csr);
     controller.startThread();
-    // Controlling not started, wait until controller thread is waiting on condition var, no work done
-    while (!controller.waitOnConditionVar.load()) {
-        std::this_thread::yield();
-    }
-
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_FALSE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_FALSE(controller.sleepCalled.load());
-    EXPECT_FALSE(controller.checkNewSubmissionCalled.load());
-
-    // Start controlling, no submissions yet, wait until controller thread is waiting on condition var again
-    controller.waitOnConditionVar.store(false);
-    EXPECT_FALSE(controller.waitOnConditionVar.load());
     csr.startControllingDirectSubmissions();
-    while (!controller.waitOnConditionVar.load()) {
+    controller.registerDirectSubmission(&csr);
+
+    while (controller.directSubmissions[&csr].taskCount != 9u) {
         std::this_thread::yield();
     }
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_TRUE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_TRUE(controller.sleepCalled.load());
-    EXPECT_FALSE(controller.checkNewSubmissionCalled.load());
-
-    // Wake up controller with new submissions, work should be done and wait again
-    controller.waitOnConditionVar.store(false);
-    controller.handlePagingFenceRequestsCalled.store(false);
-    controller.sleepCalled.store(false);
-    EXPECT_FALSE(controller.waitOnConditionVar.load());
-    EXPECT_FALSE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_FALSE(controller.sleepCalled.load());
-    csr.taskCount = 10;
-    controller.notifyNewSubmission();
-    while (!controller.waitOnConditionVar.load()) {
+    while (!controller.directSubmissions[&csr].isStopped) {
         std::this_thread::yield();
     }
-    // Work is done, verify results
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_TRUE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_TRUE(controller.sleepCalled.load());
-    EXPECT_TRUE(controller.checkNewSubmissionCalled.load());
-    EXPECT_NE(controller.directSubmissionControllingThread.get(), nullptr);
-    EXPECT_TRUE(controller.directSubmissions[&csr].isStopped.load());
-    EXPECT_EQ(10u, controller.directSubmissions[&csr].taskCount.load());
-    EXPECT_EQ(10u, csr.peekTaskCount());
-
+    {
+        std::lock_guard<std::mutex> lock(controller.directSubmissionsMutex);
+        EXPECT_NE(controller.directSubmissionControllingThread.get(), nullptr);
+        EXPECT_TRUE(controller.directSubmissions[&csr].isStopped);
+        EXPECT_EQ(controller.directSubmissions[&csr].taskCount, 9u);
+    }
     controller.stopThread();
     controller.unregisterDirectSubmission(&csr);
     executionEnvironment.directSubmissionController.release();
@@ -89,11 +62,9 @@ TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWithStart
     EXPECT_NE(controller.directSubmissionControllingThread.get(), nullptr);
     controller.startControlling();
 
-    while (!controller.waitOnConditionVar.load()) {
+    while (!controller.sleepCalled) {
         std::this_thread::yield();
     }
-
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
     controller.stopThread();
 }
 
@@ -102,11 +73,9 @@ TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWithNotSt
     controller.startThread();
     EXPECT_NE(controller.directSubmissionControllingThread.get(), nullptr);
 
-    while (!controller.waitOnConditionVar.load()) {
+    while (!controller.sleepCalled) {
         std::this_thread::yield();
     }
-
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
     controller.stopThread();
 }
 
@@ -122,67 +91,29 @@ TEST(DirectSubmissionControllerTestsMt, givenDirectSubmissionControllerWhenEnque
     DirectSubmissionControllerMock controller;
     controller.sleepCalled.store(false);
     controller.startThread();
-
-    // No fence requests, wait until controller thread is waiting on condition var
-    while (!controller.waitOnConditionVar.load()) {
+    while (!controller.sleepCalled) {
         std::this_thread::yield();
     }
-
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_FALSE(controller.handlePagingFenceRequestsCalled.load());
     EXPECT_EQ(0u, csr.pagingFenceValueToUnblock);
 
-    // Wake up controller with paging fence, work should be done and wait again
-    controller.waitOnConditionVar = false;
-    EXPECT_FALSE(controller.waitOnConditionVar.load());
-
     controller.enqueueWaitForPagingFence(&csr, 10u);
-    while (!controller.waitOnConditionVar.load()) {
+    // Wait until csr is not updated
+    while (csr.pagingFenceValueToUnblock == 0u) {
         std::this_thread::yield();
     }
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_TRUE(controller.sleepCalled.load());
-    EXPECT_TRUE(controller.handlePagingFenceRequestsCalled.load());
     EXPECT_EQ(10u, csr.pagingFenceValueToUnblock);
 
-    // Reset test state
-    controller.waitOnConditionVar.store(false);
-    controller.handlePagingFenceRequestsCalled.store(false);
-    controller.sleepCalled.store(false);
-    EXPECT_FALSE(controller.waitOnConditionVar.load());
-    EXPECT_FALSE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_FALSE(controller.sleepCalled.load());
-
-    // Start controlling, no submissions yet, wait until controller thread is waiting on condition var again
+    // Verify that controller is able to handle requests during controlling
     controller.startControlling();
-    while (!controller.waitOnConditionVar.load()) {
-        std::this_thread::yield();
-    }
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_TRUE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_TRUE(controller.sleepCalled.load());
-    EXPECT_FALSE(controller.checkNewSubmissionCalled.load());
 
-    // Reset test state again
-    controller.waitOnConditionVar.store(false);
-    controller.handlePagingFenceRequestsCalled.store(false);
-    controller.sleepCalled.store(false);
-    EXPECT_FALSE(controller.waitOnConditionVar.load());
-    EXPECT_FALSE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_FALSE(controller.sleepCalled.load());
-
-    // Wake with peging fence in controlling state
     controller.enqueueWaitForPagingFence(&csr, 20u);
-    while (!controller.waitOnConditionVar.load()) {
+
+    while (csr.pagingFenceValueToUnblock == 10u) {
         std::this_thread::yield();
     }
-    EXPECT_TRUE(controller.waitOnConditionVar.load());
-    EXPECT_TRUE(controller.handlePagingFenceRequestsCalled.load());
-    EXPECT_TRUE(controller.sleepCalled.load());
-    EXPECT_TRUE(controller.checkNewSubmissionCalled.load());
     EXPECT_EQ(20u, csr.pagingFenceValueToUnblock);
 
     controller.stopThread();
 }
 
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/opencl/test/unit_test/mt_tests/memory_manager/unified_memory_reuse_cleaner_tests_mt.cpp b/opencl/test/unit_test/mt_tests/memory_manager/unified_memory_reuse_cleaner_tests_mt.cpp
index c0d018930a..97fcb2ca5e 100644
--- a/opencl/test/unit_test/mt_tests/memory_manager/unified_memory_reuse_cleaner_tests_mt.cpp
+++ b/opencl/test/unit_test/mt_tests/memory_manager/unified_memory_reuse_cleaner_tests_mt.cpp
@@ -5,16 +5,12 @@
  *
  */
 
-#include "shared/test/common/mocks/mock_memory_manager.h"
 #include "shared/test/common/mocks/mock_usm_memory_reuse_cleaner.h"
 #include "shared/test/common/test_macros/test.h"
 namespace NEO {
 
-TEST(UnifiedMemoryReuseCleanerTestsMt, givenUnifiedMemoryReuseCleanerWhenCachesAreEmptyThenWorkerThreadIsWaitingOnConditionVar) {
-    MockMemoryManager mockMemoryManager;
-    mockMemoryManager.executionEnvironment.unifiedMemoryReuseCleaner.reset(new MockUnifiedMemoryReuseCleaner(false));
-    MockUnifiedMemoryReuseCleaner &cleaner = *static_cast<MockUnifiedMemoryReuseCleaner *>(mockMemoryManager.executionEnvironment.unifiedMemoryReuseCleaner.get());
-
+TEST(UnifiedMemoryReuseCleanerTestsMt, givenUnifiedMemoryReuseCleanerWhenSleepExpiredThenTrimOldInCachesIsCalled) {
+    MockUnifiedMemoryReuseCleaner cleaner(false);
     cleaner.callBaseStartThread = true;
     cleaner.callBaseTrimOldInCaches = false;
     EXPECT_EQ(nullptr, cleaner.unifiedMemoryReuseCleanerThread);
@@ -24,34 +20,12 @@ TEST(UnifiedMemoryReuseCleanerTestsMt, givenUnifiedMemoryReuseCleanerWhenCachesA
     EXPECT_TRUE(cleaner.keepCleaning.load());
 
     EXPECT_FALSE(cleaner.trimOldInCachesCalled);
-    auto svmAllocCache = std::make_unique<SVMAllocsManager::SvmAllocationCache>();
-
-    constexpr size_t svmAllocSize = 1024;
-    mockMemoryManager.usmReuseInfo.init(svmAllocSize, svmAllocSize);
-    svmAllocCache->memoryManager = &mockMemoryManager;
-    cleaner.registerSvmAllocationCache(svmAllocCache.get());
+    cleaner.registerSvmAllocationCache(nullptr);
     EXPECT_TRUE(cleaner.runCleaning.load());
 
-    // Caches are empty, ensure cleaner thread is waiting on condition var
-    while (!cleaner.waitOnConditionVar.load()) {
+    while (false == cleaner.trimOldInCachesCalled) {
         std::this_thread::yield();
     }
-    EXPECT_TRUE(cleaner.waitOnConditionVar.load());
-    EXPECT_TRUE(cleaner.isEmpty());
-    EXPECT_FALSE(cleaner.trimOldInCachesCalled);
-
-    // Wake cleaner thread to proceed some data
-    cleaner.waitOnConditionVar.store(false);
-    EXPECT_FALSE(cleaner.waitOnConditionVar.load());
-    SvmAllocationData allocData{0};
-    svmAllocCache->insert(svmAllocSize, nullptr, &allocData, false);
-    while (!cleaner.waitOnConditionVar.load()) {
-        std::this_thread::yield();
-    }
-    EXPECT_TRUE(cleaner.waitOnConditionVar.load());
-    EXPECT_TRUE(cleaner.isEmpty());
-    EXPECT_TRUE(cleaner.trimOldInCachesCalled);
-
     cleaner.stopThread();
     EXPECT_EQ(nullptr, cleaner.unifiedMemoryReuseCleanerThread);
     EXPECT_FALSE(cleaner.runCleaning.load());
@@ -69,4 +43,4 @@ TEST(UnifiedMemoryReuseCleanerTestsMt, givenUnifiedMemoryReuseCleanerWithNotStar
     cleaner.stopThread();
 }
 
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/shared/source/command_stream/command_stream_receiver_hw_base.inl b/shared/source/command_stream/command_stream_receiver_hw_base.inl
index 76bd18e9c1..83a6d387e3 100644
--- a/shared/source/command_stream/command_stream_receiver_hw_base.inl
+++ b/shared/source/command_stream/command_stream_receiver_hw_base.inl
@@ -1302,7 +1302,7 @@ SubmissionStatus CommandStreamReceiverHw<GfxFamily>::flushSmallTask(LinearStream
     this->latestSentTaskCount = taskCount + 1;
     auto submissionStatus = flushHandler(batchBuffer, getResidencyAllocations());
     if (submissionStatus == SubmissionStatus::success) {
-        ++taskCount;
+        taskCount++;
     }
     return submissionStatus;
 }
@@ -1478,7 +1478,6 @@ inline bool CommandStreamReceiverHw<GfxFamily>::initDirectSubmission() {
             }
         }
     }
-
     return ret;
 }
 
diff --git a/shared/source/direct_submission/direct_submission_controller.cpp b/shared/source/direct_submission/direct_submission_controller.cpp
index f86b182c44..9d6fbec34a 100644
--- a/shared/source/direct_submission/direct_submission_controller.cpp
+++ b/shared/source/direct_submission/direct_submission_controller.cpp
@@ -64,10 +64,6 @@ void DirectSubmissionController::startThread() {
 void DirectSubmissionController::stopThread() {
     runControlling.store(false);
     keepControlling.store(false);
-    {
-        std::lock_guard<std::mutex> lock(condVarMutex);
-        condVar.notify_one();
-    }
     if (directSubmissionControllingThread) {
         directSubmissionControllingThread->join();
         directSubmissionControllingThread.reset();
@@ -75,9 +71,7 @@ void DirectSubmissionController::stopThread() {
 }
 
 void DirectSubmissionController::startControlling() {
-    std::lock_guard<std::mutex> lock(condVarMutex);
-    runControlling.store(true);
-    condVar.notify_one();
+    this->runControlling.store(true);
 }
 
 void *DirectSubmissionController::controlDirectSubmissionsState(void *self) {
@@ -87,13 +81,9 @@ void *DirectSubmissionController::controlDirectSubmissionsState(void *self) {
         if (!controller->keepControlling.load()) {
             return nullptr;
         }
-
         std::unique_lock<std::mutex> lock(controller->condVarMutex);
-        while (!controller->runControlling.load() && controller->keepControlling.load() && controller->hasNoWork()) {
-            controller->wait(lock);
-        }
-
         controller->handlePagingFenceRequests(lock, false);
+
         auto isControllerNotified = controller->sleep(lock);
         if (isControllerNotified) {
             controller->handlePagingFenceRequests(lock, false);
@@ -106,37 +96,18 @@ void *DirectSubmissionController::controlDirectSubmissionsState(void *self) {
         if (!controller->keepControlling.load()) {
             return nullptr;
         }
-
         std::unique_lock<std::mutex> lock(controller->condVarMutex);
-        while (controller->keepControlling.load() && controller->hasNoWork()) {
-            controller->wait(lock);
-        }
-
         controller->handlePagingFenceRequests(lock, true);
+
         auto isControllerNotified = controller->sleep(lock);
         if (isControllerNotified) {
             controller->handlePagingFenceRequests(lock, true);
         }
-
         lock.unlock();
         controller->checkNewSubmissions();
     }
 }
 
-void DirectSubmissionController::notifyNewSubmission() {
-    if (this->hasNoWork()) {
-        ++activeSubmissionsCount;
-        std::lock_guard<std::mutex> lock(condVarMutex);
-        condVar.notify_one();
-    } else {
-        ++activeSubmissionsCount;
-    }
-}
-
-bool DirectSubmissionController::hasNoWork() {
-    return (0 == pagingFenceRequestsCount) && (0 == activeSubmissionsCount);
-}
-
 void DirectSubmissionController::checkNewSubmissions() {
     auto timeoutMode = timeoutElapsed();
     if (timeoutMode == TimeoutElapsedMode::notElapsed) {
@@ -170,7 +141,6 @@ void DirectSubmissionController::checkNewSubmissions() {
                 csr->stopDirectSubmission(false, false);
                 state.isStopped = true;
                 shouldRecalculateTimeout = true;
-                --activeSubmissionsCount;
             }
             state.taskCount = csr->peekTaskCount();
         } else {
@@ -308,19 +278,17 @@ void DirectSubmissionController::recalculateTimeout() {
 }
 
 void DirectSubmissionController::enqueueWaitForPagingFence(CommandStreamReceiver *csr, uint64_t pagingFenceValue) {
-    std::lock_guard lock(condVarMutex);
+    std::lock_guard lock(this->condVarMutex);
     pagingFenceRequests.push({csr, pagingFenceValue});
-    ++pagingFenceRequestsCount;
     condVar.notify_one();
 }
 
 void DirectSubmissionController::drainPagingFenceQueue() {
-    std::lock_guard lock(condVarMutex);
+    std::lock_guard lock(this->condVarMutex);
 
     while (!pagingFenceRequests.empty()) {
         auto request = pagingFenceRequests.front();
         pagingFenceRequests.pop();
-        --pagingFenceRequestsCount;
         request.csr->unblockPagingFenceSemaphore(request.pagingFenceValue);
     }
 }
@@ -330,7 +298,6 @@ void DirectSubmissionController::handlePagingFenceRequests(std::unique_lock<std:
     while (!pagingFenceRequests.empty()) {
         auto request = pagingFenceRequests.front();
         pagingFenceRequests.pop();
-        --pagingFenceRequestsCount;
         lock.unlock();
 
         request.csr->unblockPagingFenceSemaphore(request.pagingFenceValue);
diff --git a/shared/source/direct_submission/direct_submission_controller.h b/shared/source/direct_submission/direct_submission_controller.h
index b0de7e8ebb..3448b5572c 100644
--- a/shared/source/direct_submission/direct_submission_controller.h
+++ b/shared/source/direct_submission/direct_submission_controller.h
@@ -68,7 +68,6 @@ class DirectSubmissionController {
 
     void enqueueWaitForPagingFence(CommandStreamReceiver *csr, uint64_t pagingFenceValue);
     void drainPagingFenceQueue();
-    void notifyNewSubmission();
 
   protected:
     struct DirectSubmissionState {
@@ -96,12 +95,10 @@ class DirectSubmissionController {
     };
 
     static void *controlDirectSubmissionsState(void *self);
-    MOCKABLE_VIRTUAL void checkNewSubmissions();
+    void checkNewSubmissions();
     bool isDirectSubmissionIdle(CommandStreamReceiver *csr, std::unique_lock<std::recursive_mutex> &csrLock);
     bool isCopyEngineOnDeviceIdle(uint32_t rootDeviceIndex, std::optional<TaskCountType> &bcsTaskCount);
-    bool hasNoWork();
     MOCKABLE_VIRTUAL bool sleep(std::unique_lock<std::mutex> &lock);
-    MOCKABLE_VIRTUAL void wait(std::unique_lock<std::mutex> &lock) { condVar.wait(lock); }
     MOCKABLE_VIRTUAL SteadyClock::time_point getCpuTimestamp();
     MOCKABLE_VIRTUAL void overrideDirectSubmissionTimeouts(const ProductHelper &productHelper);
 
@@ -110,7 +107,7 @@ class DirectSubmissionController {
     void updateLastSubmittedThrottle(QueueThrottle throttle);
     size_t getTimeoutParamsMapKey(QueueThrottle throttle, bool acLineStatus);
 
-    MOCKABLE_VIRTUAL void handlePagingFenceRequests(std::unique_lock<std::mutex> &lock, bool checkForNewSubmissions);
+    void handlePagingFenceRequests(std::unique_lock<std::mutex> &lock, bool checkForNewSubmissions);
     MOCKABLE_VIRTUAL TimeoutElapsedMode timeoutElapsed();
     std::chrono::microseconds getSleepValue() const { return std::chrono::microseconds(this->timeout / this->bcsTimeoutDivisor); }
 
@@ -136,8 +133,6 @@ class DirectSubmissionController {
 
     std::condition_variable condVar;
     std::mutex condVarMutex;
-    std::atomic_uint activeSubmissionsCount = 0;
-    std::atomic_uint pagingFenceRequestsCount = 0;
 
     std::queue<WaitForPagingFenceRequest> pagingFenceRequests;
 };
diff --git a/shared/source/direct_submission/direct_submission_hw.inl b/shared/source/direct_submission/direct_submission_hw.inl
index b58ccccdcd..e65517f17d 100644
--- a/shared/source/direct_submission/direct_submission_hw.inl
+++ b/shared/source/direct_submission/direct_submission_hw.inl
@@ -10,7 +10,6 @@
 #include "shared/source/command_stream/submissions_aggregator.h"
 #include "shared/source/debug_settings/debug_settings_manager.h"
 #include "shared/source/device/device.h"
-#include "shared/source/direct_submission/direct_submission_controller.h"
 #include "shared/source/direct_submission/direct_submission_hw.h"
 #include "shared/source/direct_submission/relaxed_ordering_helper.h"
 #include "shared/source/execution_environment/execution_environment.h"
@@ -589,9 +588,6 @@ template <typename GfxFamily, typename Dispatcher>
 bool DirectSubmissionHw<GfxFamily, Dispatcher>::submitCommandBufferToGpu(bool needStart, uint64_t gpuAddress, size_t size, bool needWait, const ResidencyContainer *allocationsForResidency) {
     if (needStart) {
         this->ringStart = this->submit(gpuAddress, size, allocationsForResidency);
-        if (auto controller = rootDeviceEnvironment.executionEnvironment.directSubmissionController.get()) {
-            controller->notifyNewSubmission();
-        }
         return this->ringStart;
     } else {
         if (needWait) {
diff --git a/shared/source/direct_submission/linux/direct_submission_controller_linux.cpp b/shared/source/direct_submission/linux/direct_submission_controller_linux.cpp
index 57d46b7687..679b5d14a6 100644
--- a/shared/source/direct_submission/linux/direct_submission_controller_linux.cpp
+++ b/shared/source/direct_submission/linux/direct_submission_controller_linux.cpp
@@ -17,4 +17,4 @@ bool DirectSubmissionController::sleep(std::unique_lock<std::mutex> &lock) {
 void DirectSubmissionController::overrideDirectSubmissionTimeouts(const ProductHelper &productHelper) {
 }
 
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/shared/source/direct_submission/windows/direct_submission_controller_windows.cpp b/shared/source/direct_submission/windows/direct_submission_controller_windows.cpp
index 4ca7aa9979..b6f675ebd0 100644
--- a/shared/source/direct_submission/windows/direct_submission_controller_windows.cpp
+++ b/shared/source/direct_submission/windows/direct_submission_controller_windows.cpp
@@ -28,4 +28,4 @@ void DirectSubmissionController::overrideDirectSubmissionTimeouts(const ProductH
     this->maxTimeout = std::chrono::microseconds(maxTimeoutUs);
 }
 
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/shared/source/memory_manager/unified_memory_manager.cpp b/shared/source/memory_manager/unified_memory_manager.cpp
index 87d15f33b2..a0f9bc7f05 100644
--- a/shared/source/memory_manager/unified_memory_manager.cpp
+++ b/shared/source/memory_manager/unified_memory_manager.cpp
@@ -67,7 +67,7 @@ bool SVMAllocsManager::SvmAllocationCache::insert(size_t size, void *ptr, SvmAll
         return false;
     }
 
-    std::unique_lock<std::mutex> lock(this->mtx);
+    std::lock_guard<std::mutex> lock(this->mtx);
     if (svmData->device ? svmData->device->shouldLimitAllocationsReuse() : memoryManager->shouldLimitAllocationsReuse()) {
         return false;
     }
@@ -107,12 +107,6 @@ bool SVMAllocsManager::SvmAllocationCache::insert(size_t size, void *ptr, SvmAll
                            .operationType = CacheOperationType::insert,
                            .isSuccess = isSuccess});
     }
-
-    if (auto usmReuseCleaner = this->memoryManager->peekExecutionEnvironment().unifiedMemoryReuseCleaner.get()) {
-        lock.unlock();
-        usmReuseCleaner->notifySvmAllocationsCacheUpdate();
-    }
-
     return isSuccess;
 }
 
diff --git a/shared/source/memory_manager/unified_memory_manager.h b/shared/source/memory_manager/unified_memory_manager.h
index c7f4cf455f..cd46434b21 100644
--- a/shared/source/memory_manager/unified_memory_manager.h
+++ b/shared/source/memory_manager/unified_memory_manager.h
@@ -208,7 +208,6 @@ class SVMAllocsManager {
         static bool allocUtilizationAllows(size_t requestedSize, size_t reuseCandidateSize);
         static bool alignmentAllows(void *ptr, size_t alignment);
         bool isInUse(SvmCacheAllocationInfo &cacheAllocInfo);
-        bool isEmpty() { return allocations.empty(); }
         void *get(size_t size, const UnifiedMemoryProperties &unifiedMemoryProperties);
         void trim();
         void trimOldAllocs(std::chrono::high_resolution_clock::time_point trimTimePoint, bool trimAll);
diff --git a/shared/source/memory_manager/unified_memory_reuse_cleaner.cpp b/shared/source/memory_manager/unified_memory_reuse_cleaner.cpp
index 69406ef5c8..7b2254b79c 100644
--- a/shared/source/memory_manager/unified_memory_reuse_cleaner.cpp
+++ b/shared/source/memory_manager/unified_memory_reuse_cleaner.cpp
@@ -25,10 +25,6 @@ UnifiedMemoryReuseCleaner::~UnifiedMemoryReuseCleaner() {
 void UnifiedMemoryReuseCleaner::stopThread() {
     keepCleaning.store(false);
     runCleaning.store(false);
-    {
-        std::lock_guard<std::mutex> lock(condVarMutex);
-        condVar.notify_one();
-    }
     if (unifiedMemoryReuseCleanerThread) {
         unifiedMemoryReuseCleanerThread->join();
         unifiedMemoryReuseCleanerThread.reset();
@@ -48,22 +44,11 @@ void *UnifiedMemoryReuseCleaner::cleanUnifiedMemoryReuse(void *self) {
         if (!cleaner->keepCleaning.load()) {
             return nullptr;
         }
-
-        std::unique_lock lock(cleaner->condVarMutex);
-        while (cleaner->keepCleaning.load() && cleaner->isEmpty()) {
-            cleaner->wait(lock);
-        }
-
         NEO::sleep(sleepTime);
         cleaner->trimOldInCaches();
     }
 }
 
-void UnifiedMemoryReuseCleaner::notifySvmAllocationsCacheUpdate() {
-    std::lock_guard<std::mutex> lock(condVarMutex);
-    condVar.notify_one();
-}
-
 void UnifiedMemoryReuseCleaner::registerSvmAllocationCache(SvmAllocationCache *cache) {
     std::lock_guard<std::mutex> lockSvmAllocationCaches(this->svmAllocationCachesMutex);
     this->svmAllocationCaches.push_back(cache);
@@ -98,4 +83,4 @@ void UnifiedMemoryReuseCleaner::startThread() {
     this->unifiedMemoryReuseCleanerThread = Thread::createFunc(cleanUnifiedMemoryReuse, reinterpret_cast<void *>(this));
 }
 
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/shared/source/memory_manager/unified_memory_reuse_cleaner.h b/shared/source/memory_manager/unified_memory_reuse_cleaner.h
index 85d63d3fd0..485e585f04 100644
--- a/shared/source/memory_manager/unified_memory_reuse_cleaner.h
+++ b/shared/source/memory_manager/unified_memory_reuse_cleaner.h
@@ -11,7 +11,6 @@
 #include "shared/source/memory_manager/unified_memory_manager.h"
 
 #include <chrono>
-#include <condition_variable>
 #include <memory>
 #include <mutex>
 #include <vector>
@@ -34,12 +33,6 @@ class UnifiedMemoryReuseCleaner : NEO::NonCopyableAndNonMovableClass {
 
     void registerSvmAllocationCache(SvmAllocationCache *cache);
     void unregisterSvmAllocationCache(SvmAllocationCache *cache);
-    MOCKABLE_VIRTUAL void wait(std::unique_lock<std::mutex> &lock) { condVar.wait(lock); }
-    MOCKABLE_VIRTUAL bool isEmpty() {
-        std::unique_lock<std::mutex> lock(svmAllocationCachesMutex);
-        return std::all_of(svmAllocationCaches.begin(), svmAllocationCaches.end(), [](const auto &it) { return it->isEmpty(); });
-    }
-    void notifySvmAllocationsCacheUpdate();
 
   protected:
     void startCleaning() { runCleaning.store(true); };
@@ -50,9 +43,6 @@ class UnifiedMemoryReuseCleaner : NEO::NonCopyableAndNonMovableClass {
     std::vector<SvmAllocationCache *> svmAllocationCaches;
     std::mutex svmAllocationCachesMutex;
 
-    std::mutex condVarMutex;
-    std::condition_variable condVar;
-
     std::atomic_bool runCleaning = false;
     std::atomic_bool keepCleaning = true;
 
diff --git a/shared/test/common/mocks/mock_usm_memory_reuse_cleaner.h b/shared/test/common/mocks/mock_usm_memory_reuse_cleaner.h
index 7f4ded2b05..57a4813388 100644
--- a/shared/test/common/mocks/mock_usm_memory_reuse_cleaner.h
+++ b/shared/test/common/mocks/mock_usm_memory_reuse_cleaner.h
@@ -20,8 +20,6 @@ struct MockUnifiedMemoryReuseCleaner : public UnifiedMemoryReuseCleaner {
         trimOldInCachesCalled = true;
         if (callBaseTrimOldInCaches) {
             UnifiedMemoryReuseCleaner::trimOldInCaches();
-        } else {
-            clearCaches();
         }
     }
     void startThread() override {
@@ -29,17 +27,8 @@ struct MockUnifiedMemoryReuseCleaner : public UnifiedMemoryReuseCleaner {
             UnifiedMemoryReuseCleaner::startThread();
         }
     };
-    void wait(std::unique_lock<std::mutex> &lock) override {
-        waitOnConditionVar.store(true);
-        UnifiedMemoryReuseCleaner::wait(lock);
-    };
-    void clearCaches() {
-        std::lock_guard<std::mutex> lock(svmAllocationCachesMutex);
-        svmAllocationCaches.clear();
-    }
-    std::atomic_bool trimOldInCachesCalled = false;
-    std::atomic_bool waitOnConditionVar = false;
+    bool trimOldInCachesCalled = false;
     bool callBaseStartThread = false;
     bool callBaseTrimOldInCaches = true;
 };
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file
diff --git a/shared/test/unit_test/direct_submission/direct_submission_controller_mock.h b/shared/test/unit_test/direct_submission/direct_submission_controller_mock.h
index 6de72431ca..f450be5452 100644
--- a/shared/test/unit_test/direct_submission/direct_submission_controller_mock.h
+++ b/shared/test/unit_test/direct_submission/direct_submission_controller_mock.h
@@ -42,21 +42,6 @@ struct DirectSubmissionControllerMock : public DirectSubmissionController {
         }
     }
 
-    void wait(std::unique_lock<std::mutex> &lock) override {
-        waitOnConditionVar.store(true);
-        DirectSubmissionController::wait(lock);
-    }
-
-    void handlePagingFenceRequests(std::unique_lock<std::mutex> &lock, bool checkForNewSubmissions) override {
-        handlePagingFenceRequestsCalled.store(true);
-        DirectSubmissionController::handlePagingFenceRequests(lock, checkForNewSubmissions);
-    }
-
-    void checkNewSubmissions() override {
-        checkNewSubmissionCalled.store(true);
-        DirectSubmissionController::checkNewSubmissions();
-    }
-
     SteadyClock::time_point getCpuTimestamp() override {
         return cpuTimestamp;
     }
@@ -74,9 +59,6 @@ struct DirectSubmissionControllerMock : public DirectSubmissionController {
     std::atomic<bool> sleepReturnValue{false};
     std::atomic<TimeoutElapsedMode> timeoutElapsedReturnValue{TimeoutElapsedMode::notElapsed};
     std::atomic<bool> timeoutElapsedCallBase{false};
-    std::atomic<bool> waitOnConditionVar{false};
-    std::atomic<bool> checkNewSubmissionCalled{false};
-    std::atomic<bool> handlePagingFenceRequestsCalled{false};
     bool callBaseSleepMethod = false;
 };
-} // namespace NEO
+} // namespace NEO
\ No newline at end of file