Adds ffmpeg threads options

Author: Marcos Cordeiro

Wasari.Cli/Commands/DownloadCommand.cs

@@ -1,4 +1,4 @@
-using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations;
 using CliFx;
 using CliFx.Attributes;
 using CliFx.Exceptions;
@@ -93,6 +93,9 @@ public DownloadCommand(EnvironmentService environmentService, ILogger<DownloadCo
 
     [CommandOption("enrich-episodes", Description = "If true, will try to enrich episodes with metadata from TVDB (Fixes season and episode numbers)")]
     public bool EnrichEpisodes { get; init; } = true;
+    
+    [CommandOption("ffmpeg-threads", Description = "Number of threads to use for FFmpeg")]
+    public int FfmpegThreads { get; init; } = 8;
 
     private EnvironmentService EnvironmentService { get; }
 
@@ -196,6 +199,7 @@ public async ValueTask ExecuteAsync(IConsole console)
             o.UseTemporaryEncodingPath = UseTemporaryEncodingPath;
             o.Shaders = Shaders;
             o.Resolution = Resolution;
+            o.Threads = FfmpegThreads;
         });
         serviceCollection.Configure<AuthenticationOptions>(o =>
         {

Wasari.FFmpeg/FFmpegOptions.cs

@@ -11,4 +11,6 @@ public record FFmpegOptions
     public bool UseNvidiaAcceleration { get; set; }
 
     public bool UseTemporaryEncodingPath { get; set; }
+    
+    public int Threads { get; set; } = 8;
 }

Wasari.FFmpeg/FFmpegService.cs

@@ -55,21 +55,22 @@ private static FileInfo CompileShaders(IEnumerable<IFFmpegShader> shaders)
 
     private async IAsyncEnumerable<string> BuildArgumentsForEpisode(IWasariEpisode episode, string filePath)
     {
+        yield return $"-threads {Options.Value.Threads}";
+        
         await using var providerScope = Provider.CreateAsyncScope();
         var inputs = await episode.InputsFactory(providerScope.ServiceProvider);
 
         if (inputs.Count == 0)
         {
             throw new EmptyFFmpegInputsException(episode);
         }
-
-
+        
         var resolution = Options.Value.Resolution ?? inputs.Where(i => i.Type is InputType.Video or InputType.VideoWithAudio)
             .Select(i =>
             {
                 var mediaAnalysis = FFProbe.Analyse(new Uri(i.Url));
 
-                var videoStream = i is IWasariEpisodeInputStreamSelector { VideoIndex: { } } streamSelector ? mediaAnalysis.VideoStreams.Single(o => o.Index == streamSelector.VideoIndex.Value) : mediaAnalysis.PrimaryVideoStream;
+                var videoStream = i is IWasariEpisodeInputStreamSelector { VideoIndex: not null } streamSelector ? mediaAnalysis.VideoStreams.Single(o => o.Index == streamSelector.VideoIndex.Value) : mediaAnalysis.PrimaryVideoStream;
                 return videoStream == null ? null : new FFmpegResolution(videoStream.Width, videoStream.Height);
             }).Single(i => i != null);