Skip to content

Commit

Permalink
fix: 스레드 풀 개수 수정
Browse files Browse the repository at this point in the history
  • Loading branch information
kariskan committed Aug 28, 2024
1 parent 2e27791 commit 8a66208
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,6 @@ public void produce(InitiateMultipartUploadResult initResponse, String currentFi
log.info("current queue size: {}", workQueue.size());
long start = System.currentTimeMillis();
uploadPart(initResponse.getUploadId(), currentFileName, partNumber, contentBuffer, bufferLength, partETags);
log.info("uploadPart execute time: {}", System.currentTimeMillis() - start);
AtomicInteger currentConsumeCount = currentPartCountMap.get(currentFileName);
if (currentConsumeCount != null) {
currentConsumeCount.incrementAndGet();
Expand All @@ -87,6 +86,7 @@ public void produce(InitiateMultipartUploadResult initResponse, String currentFi
&& currentConsumeCount.get() >= maxConsumeCount) {
completeFileUpload(initResponse.getUploadId(), currentFileName, partETags);
}
log.info("uploadPart execute time: {}", System.currentTimeMillis() - start);
});
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
public class CommonConstant {
public static final Character[] FILE_NAME_BLACK_LIST = {'\\', '/', ':', '*', '?', '"', '<', '>', '|'};
public static final int MAX_FOLDER_DEPTH = 50;
public static final int FILE_WRITER_CORE_POOL_SIZE = 150;
public static final int FILE_WRITER_CORE_POOL_SIZE = 20;
public static final int FILE_WRITER_MAXIMUM_POOL_SIZE = 200;
public static final int FILE_WRITER_KEEP_ALIVE_TIME = 10;
public static final int FILE_WRITER_QUEUE_SIZE = 400;
Expand Down

0 comments on commit 8a66208

Please sign in to comment.