0

我有一个包含许多线程的程序，让我们以六个线程为例。其中五个应该能够同时使用给定资源，但如果发生给定条件，最后一个线程不应该，并且应该等到该条件结束。

据我了解，不能使用 ReentrantLock，因为它一次只能由一个线程持有。另一方面，信号量可以一次由多个线程持有，但我找不到将条件附加到获取方法的方法。

这个高级对象可以做到这一点，或者我将不得不使用通知来实现这个功能并直接等待？

例如。

class A{
   getResource{ ... }
}

//This Runable could be spawn many times at the same time
class B implements Runnable{
   run {
      setConditionToTrue
      getResource
      ...
      getResource
      ...
      getResource
      setConditionToFalse
   }
}

//This will be working forever but only one Thread
class C implements Runnable{
   run{
      loop{
         if(Condition == true) wait
         getResource
      }
   }
}

提前谢谢朋友们

4

2 回答 2

2

我在这里重申您的问题：您希望您的 B 线程同时访问共享资源，但您的 C 线程应该在使用资源之前等待某些条件发生。

如果我正确理解您的问题，您可以使用它ReentrantLock来解决您的问题。

引入一个新的函数调用getAccess()，让C线程调用这个函数来获取共享资源。引入另外两个函数来允许和停止对共享资源的访问。

class A {

  private final ReentrantLock lock = new ReentrantLock();
  private Condition someCondition = lock.newCondition();
  private boolean bCondition = false;

  getResource{ ... } // Your existing method used by B threads

  getAccess() { // Protected access to some resource, called by C thread
    lock.acquire();

    try {
      if (!bCondition)
        someCondition.await(); // B thread will wait here but releases the lock
    } finally {
      lock.release();
    }
  }

  allowAccess() { // B thread can call this func to notify C and allow access
    lock.acquire();
    try {
      bCondition = true;
      someCondition.signal(); // Decided to release the resource
    } finally {
      lock.release();
    }
  }

  stopAccess() { // B thread can stop the access
    lock.acquire();
    try {
      bCondition = false;
    } finally {
      lock.release();
    }
  }

}
于 2012-06-23T05:00:26.520 回答
0

如果您希望多个线程共享一个资源，您需要更具体地了解该共享的含义。通常，这意味着要区分读取资源当前值的线程和更改值的其他线程。如果写入是无竞争且稳定的，这意味着是并发读取/独占写入模式（'crew'）。

在 Java API 中，这是由ReentrantReadWriteLock提供的。还有其他值得考虑的替代方案，例如 JCSP 中精心实施的Crew。

使用 [J]CSP，还可以使用不同的模式：将公共资源包装在自己的线程中，并通过所有客户端线程的共享 JCSP 通道提供对其的访问。鉴于线程通信图是非循环的（更多），这种客户端-服务器模式易于理解和实现，并且具有形式上无死锁的额外好处。

于 2012-06-24T08:16:48.583 回答