Java实现选择性同步

发布于 2024-12-12 13:23:05 字数 299 浏览 0 评论 0原文

我在应用程序中遇到一个问题，其中运行两个具有相同参数的线程，发生冲突。一种解决方案是使用同步块，但由于问题仅发生在具有相同参数的线程上，因此效率非常低。我想到的一种方法是使用并发映射将参数组合存储为键，将对象存储为值，每当线程开始操作时，它首先检查映射是否包含键（参数组合），如果是，则执行等待为该组合存储的对象。线程最后会从映射中删除该对象并对其调用通知。这种方法的问题是为相同的参数组合生成相同的对象。例如：如果线程1插入map，然后调用notify并删除它，线程2可能会退出等待，但其他线程永远不会出来，因为对象从map中丢失。

对于这个问题有不同的优雅方法吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

蝶舞 2024-12-19 13:23:05

创建参数组合池。每次需要保证一个线程正在运行时，请调用 Pool.acquire(params)。

像这样使用它：

使用漂亮的 hashCode 和 equals 将参数包装在一个对象中。

在主题中：

synchronized(pool) {
  pool.acquire(myParams);
}
// do the work
synchronized(pool) {
  pool.release(myParams);
}

池：

class Pool {
  Set<Params> lockedParams;

  // In Pool - note that this is synchronized!
  void acquire(Params params) {
    Params lock = lockedParams.get(params);
    if(lock != null) {
      // Locked by another thread
      lock.wait();
    }
    lockedParams.add(params);
  }

  void release(Params params) {
    Params lock = lockedParams.remove(params);
    lock.notifyAll();
  }
}

这是一个想法。您需要为现实生活中的情况添加一些错误处理（finally 中的 release()，在本例中处理 Pool 中的 null lock .release() 等）。

Create a pool of parameter combinations. Every time you need to guarantee one thread is running, call Pool.acquire(params).

Use it like this:

Wrap parameters in an object with nice hashCode and equals.

In Thread:

synchronized(pool) {
  pool.acquire(myParams);
}
// do the work
synchronized(pool) {
  pool.release(myParams);
}

Pool:

class Pool {
  Set<Params> lockedParams;

  // In Pool - note that this is synchronized!
  void acquire(Params params) {
    Params lock = lockedParams.get(params);
    if(lock != null) {
      // Locked by another thread
      lock.wait();
    }
    lockedParams.add(params);
  }

  void release(Params params) {
    Params lock = lockedParams.remove(params);
    lock.notifyAll();
  }
}

That's one idea. You need to add some error handling for real life cases (release() in finally, in this case handle null lock in Pool.release(), etc.).

回复收藏 0 原文