Aspiring / FresherJava Backend Developer

// Exact Code from: Video-Streaming-App/src/main/java/.../impl/VideoServiceImpl.java
@Service
@Slf4j
@RequiredArgsConstructor
public class VideoServiceImpl implements VideoService {

    private final VideoRepository videoRepository;
    private final FileStorageService fileStorageService;
    private final VideoServiceHelper helper;
    private final Semaphore ffmpegSemaphore = new Semaphore(3);

    @Override
    public void processVideo(String videoId) {
        CompletableFuture.runAsync(() -> {
            try {
                ffmpegSemaphore.acquire();

                helper.runFFmpegConversion(videoId);
                helper.uploadFolderToCloud(videoId);

                videoRepository.findById(videoId).ifPresent(video -> {
                    video.setStatus("COMPLETED");
                    video.setUrl(r2PublicUrl + "/videos/" + videoId + "/master.m3u8");
                    videoRepository.save(video);
                });

                FileSystemUtils.deleteRecursively(Paths.get(hslDir, videoId));

            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                helper.updateVideoStatus(videoId, "FAILED");
            } finally {
                ffmpegSemaphore.release();
            }
        }, Executors.newVirtualThreadPerTaskExecutor());
    }
}