4

我正在尝试使用互斥锁保护我的隔离存储，以便我可以从移动应用程序和BackgroundAudioPlayer.

这些是我的助手类来访问 isostorage 中的文件：

    public static async Task WriteToFile(string text)
    {
        using (var mut = new Mutex(false, "IsoStorageMutex"))
        {
            mut.WaitOne();
            try
            {
                // Get the text data from the textbox. 
                byte[] fileBytes = System.Text.Encoding.UTF8.GetBytes(text.ToCharArray());

                // Get the local folder.
                var local = ApplicationData.Current.LocalFolder;

                // Create a new folder name DataFolder.
                var dataFolder = await local.CreateFolderAsync("MusicFolder",
                                                               CreationCollisionOption.OpenIfExists);

                // Create a new file named DataFile.txt.
                var file = await dataFolder.CreateFileAsync("Streams.txt",
                                                            CreationCollisionOption.ReplaceExisting);

                // Write the data from the textbox.
                using (var s = await file.OpenStreamForWriteAsync())
                {
                    s.Write(fileBytes, 0, fileBytes.Length);
                }
            }
            finally
            {
                mut.ReleaseMutex();
            }
        }
    }

    public static async Task<string> ReadFile()
    {
        using (var mut = new Mutex(false, "IsoStorageMutex"))
        {
              mut.WaitOne();
              var result = String.Empty;
              try
              {
                  // Get the local folder.
                  var local = ApplicationData.Current.LocalFolder;

                  if (local != null)
                  {
                      // Get the DataFolder folder.
                      var dataFolder = await local.GetFolderAsync("MusicFolder");

                      // Get the file.
                      var file = await dataFolder.OpenStreamForReadAsync("Streams.txt");

                      // Read the data.

                      using (var streamReader = new StreamReader(file))
                      {
                          result = streamReader.ReadToEnd();
                      }
                  }
              }
              finally
              {
                  mut.ReleaseMutex();
              }
              return result;
        }
    }

但是当我尝试在后台代理中访问它时，我收到了这个错误：

 Object synchronization method was called from an unsynchronized block of code.

堆栈跟踪：

   at System.Threading.Mutex.ReleaseMutex()
   at YouRadio.IsolatedStorage.StorageHelpers.<ReadFile>d__b.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
   at YouRadio.AudioPlaybackAgent.AudioPlayer.<AddTracksFromIsoStorageToPlaylist>d__6.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.GetResult()
   at YouRadio.AudioPlaybackAgent.AudioPlayer.<OnUserAction>d__2.MoveNext()

我做错了什么？

4

1 回答 1

1

您以错误的方式实施 Mutex。您应该在您的IsolatedStorageHelper类和使用该实例的方法中创建它的全局实例。

public class IsolatedStorageHelper
{
    private static Mutex mut = new Mutex(false, "IsoStorageMutex");

    public static async Task WriteToFile(string text)
    {
        mut.WaitOne();
        try
        {
            ...
        }
        finally
        {
            mut.ReleaseMutex();
        }
    }

    public static async Task<string> ReadFile()
    {
          mut.WaitOne();
          var result = String.Empty;
          try
          {
              ...
          }
          finally
          {
              mut.ReleaseMutex();
          }
          return result;
    }
}

互斥锁具有线程亲和性，互斥锁的所有者是线程。获取它的线程也必须是调用ReleaseMutex () 的线程。打破这使得这个讨厌的异常被抛出。

根据您的要求，您可能还有不同的互斥锁用于读取和写入文件。此外，如果您的类中的所有方法都是静态的，您可以将其设为单例类。这样你就可以有一个私有构造函数来初始化互斥锁和其他东西。

于 2014-03-25T11:03:39.803 回答