Fichier utilisé par un autre processus dans le service Windows

Question

J'ai écrit le code suivant qui fonctionne bien mais le problème est que parfois cela me donne file being used by another process ces deux travaux accèdent et écrivent le même fichier. ClickProfileJob s'exécute en premier et répète après 5 secondes, puis le deuxième travail ClickLikeJob selon l'horaire de 5 secondes. J'ai vu quelques solutions qui avaient suggéré la même technique que j'ai codé ci-dessous.

using Quartz; 
    using System; 
    using System.IO; 
    using Topshelf; 
    using Topshelf.Quartz; 

    namespace FinyaConsole 
    { 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      userCreds creds = new userCreds(); 

      if (creds.checkUser().Length > 3) 
      { 
       HostFactory.Run(x => 
       { 
        x.Service<GiveHeartsService>(s => 
        { 
         s.WhenStarted(service => service.OnStart()); 
         s.WhenStopped(service => service.OnStop()); 
         s.ConstructUsing(() => new GiveHeartsService()); 

         s.ScheduleQuartzJob(q => 
          q.WithJob(() => 
           JobBuilder.Create<ClickProfileJob>().Build()) 
           .AddTrigger(() => TriggerBuilder.Create() 
            .WithSimpleSchedule(b => b 
             .WithIntervalInSeconds(5) 
             .RepeatForever()) 
            .Build())); 

         s.ScheduleQuartzJob(q => 
          q.WithJob(() => 
           JobBuilder.Create<ClickLikeJob>().Build()) 
           .AddTrigger(() => TriggerBuilder.Create() 
            .WithSimpleSchedule(b => b 
             .WithIntervalInSeconds(5) 
             .RepeatForever()) 
            .Build())); 


        }); 

        //.DependsOnEventLog() 

        x.RunAsLocalSystem() 
         .StartAutomaticallyDelayed() 
         .EnableServiceRecovery(rc => rc.RestartService(1)); 

        x.SetServiceName("FinyaHearts"); 
        x.SetDisplayName("FinyaHearts"); 
        x.SetDescription("This is a service."); 
       }); 
      } 
     } 
    } 
     public class ClickProfileJob : IJob 
     { 
      public void Execute(IJobExecutionContext context) 
      { 
       try 
       { 
        using (StreamWriter sw = new StreamWriter(".\\visits_to_others.txt", true)) 
        { 

         //Write a line of text 
         sw.WriteLine($"[{DateTime.Now}] Welcome from ClickProfileJob!"); 
         Console.WriteLine($"[{DateTime.Now}] Welcome from ClickProfileJob!"); 
         //System.IO.File.WriteAllText(@"path\visit_users.txt", userLink); 
         //Close the file 
         sw.Flush(); 
         sw.Dispose(); 
         sw.Close(); 
        } 
       } 
       catch (Exception e) 
       { 
        Console.WriteLine("Exception: " + e.Message); 
       } 
       finally 
       { 
        //Console.WriteLine("Executing finally block."); 
       } 
      } 
     } 

     public class ClickLikeJob : IJob 
     { 
      public void Execute(IJobExecutionContext context) 
      { 
       try 
       { 
        using (StreamWriter sw = new StreamWriter(".\\visits_to_others.txt", true)) 
        { 

         //Write a line of text 
         sw.WriteLine($"[{DateTime.Now}] Welcome from ClickLikeJob!"); 
         Console.WriteLine($"[{DateTime.Now}] Welcome from ClickLikeJob!"); 
         //System.IO.File.WriteAllText(@"path\visit_users.txt", userLink); 
         //Close the file 
         sw.Flush(); 
         sw.Dispose(); 
         sw.Close(); 
        } 
       } 
       catch (Exception e) 
       { 
        Console.WriteLine("Exception: " + e.Message); 
       } 
       finally 
       { 
        //Console.WriteLine("Executing finally block."); 
       } 
      } 
     } 
    } 

Answer 1

Ce n'est pas un problème spécifique au quartz. Vous pouvez utiliser un SemaphoreSlim ou mieux un lock simple. Créez simplement un travail de base et dérivez vos autres Jobs. Puis verrouillez le LockObject dans les deux Jobs.

public abstract class LockableJobBase 
{ 
    protected static object LockObject = new object(); 
} 


public class ClickProfileJob : LockableJobBase, IJob 
{ 
    public void Execute(IJobExecutionContext context) 
    { 
     try 
     { 
      lock (LockObject) 
      { 
       using (StreamWriter sw = new StreamWriter(".\\visits_to_others.txt", true)) 
       { 
        // your sw stuff 
       } 
      } 

     } 
     catch (Exception e) 
     { 
      Console.WriteLine("Exception: " + e.Message); 
     } 
     finally 
     { 
      //Console.WriteLine("Executing finally block."); 
     } 
    } 
} 

public class ClickLikeJob : LockableJobBase, IJob 
{ 
    public void Execute(IJobExecutionContext context) 
    { 
     try 
     { 
      lock (LockObject) 
      { 
       using (StreamWriter sw = new StreamWriter(".\\visits_to_others.txt", true)) 
       { 
        // your sw stuff 
       } 
      } 

     } 
     catch (Exception e) 
     { 
      Console.WriteLine("Exception: " + e.Message); 
     } 
     finally 
     { 
      //Console.WriteLine("Executing finally block."); 
     } 
    } 
}