同步对象序列化(安卓)

Question

tl;dr：我有两个线程，其中一个实现对象，另一个尝试读取对象。如何避免冲突，即同步对文件的访问？

更多信息：我有使用 AsyncTask 获取数据然后序列化对象的服务：

  @Override
  protected Boolean doInBackground(Void... params) {
      FeedItem currentItem = mParser.parseFeed();
      Util.saveItem(UpdateService.this, currentItem);       
  }

对象序列化：

public class Util {
    private static final String sFileName = "feedobject";
    public static FeedItem loadItem(Context context) {
        FeedItem result = null;
        try {
            FileInputStream fis = context.openFileInput(sFileName);
            ObjectInputStream is = new ObjectInputStream(fis);
            result = (FeedItem) is.readObject();
            is.close();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        return result;
    }
    public static void saveItem(Context context, FeedItem item) {
        FileOutputStream fos;
        try {
            fos = context.openFileOutput(sFileName, Context.MODE_PRIVATE);
            ObjectOutputStream os = new ObjectOutputStream(fos);
            os.writeObject(item);
            os.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

我还尝试从活动(即从 UI 线程(读取对象。

mTextView.setText(Html.fromHtml(Util.loadItem(this).message));

Answer 1

如果您可以在Android下重命名文件，则可以将对象写入临时文件"feedobject.t"然后将其重命名为"feedobject"这应该是原子的。

private static final String sFileName = "feedobject";
private static final String tempFileName = "feedobject.t";
...
File tempFile = new File(tempFileName);
... // write the file
tempFile.renameTo(new File(sFileName));

如果这不起作用，那么您将被迫使用同步锁。 使用者应锁定并等待生产者完成写入。 生产者需要锁定以确保它仅在使用者不读取时才写入。

您可以只同步saveItem和loadItem方法，这将锁定类：

public static synchronized FeedItem loadItem(Context context) {
    ...
public static synchronized void saveItem(Context context, FeedItem item) {
    ...

最好创建一个锁定对象并锁定它：

private static final Object itemLock = new Object();

然后在loadItem和saveItem方法中，您将锁定该对象：

public static FeedItem loadItem(Context context) {
    synchronized (itemLock) {
        // do the reading...
    }

希望这有帮助。