Skip to content

Commit 1d854f1

Browse files
authored
Allow up to 32 task updates at a given time (#703)
1 parent 7c19751 commit 1d854f1

File tree

4 files changed

+118
-179
lines changed

4 files changed

+118
-179
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ All notable changes to this project will be documented in this file.
1414
- Move `notification` package from `iexec-commons-poco` to `iexec-core-library`. (#697 #698)
1515
- Move `PublicConfiguration` class from `iexec-common` to `iexec-core-library`. (#699)
1616
- Create `ConfigServerClient` instance and use it. (#700)
17+
- Allow up to 32 task updates at a given time. (#703)
1718

1819
### Bug Fixes
1920

src/main/java/com/iexec/core/task/update/TaskUpdateRequestManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public class TaskUpdateRequestManager {
4040
/**
4141
* Max number of threads to update task for each core.
4242
*/
43-
private static final int TASK_UPDATE_THREADS_POOL_SIZE = Runtime.getRuntime().availableProcessors() * 2;
43+
private static final int TASK_UPDATE_THREADS_POOL_SIZE = 32;
4444

4545
// Working with semaphore to guarantee at most 1 item in queue and 1 running thread
4646
private final ExpiringMap<String, Semaphore> taskExecutionLockRunner = ExpiringMap.builder()

0 commit comments

Comments
 (0)