2

我正在编写一个应用程序，我需要从单个文件中读取块，每个块大约是 512 字节。我还需要同时写块。

我的想法之一是管理读者和作者BlockReader implements Runnable。BlockWriter implements RunnableBlockManager

我在发现的大多数示例中看到的问题是锁定问题和潜在的死锁情况。任何想法如何实现这一点？

4

2 回答 2

6

我会推荐这本书java Concurrency in Practice，在本例中为第 5.3 节（生产者-消费者模式）。

您的解决方案可能类似于：

BlockingQueue<Data> queue = 
    new  LinkedBlockingQueue<Data>(MAX_BLOCKS_IN_QUEUE_UNTIL_BLOCK );

for (int i=0; i < MAX_DATA_PRODUCERS; i++ ) {
   new Thread( new DataProducer( queue ) ).start();
}

new Thread(DataWriter( queue )).start

显然 DataProducer 和 DataWriter 是可运行的。

 class DataProducer implements Runnable {
    ...
    queue.put(data); // blocks if MAX_BLOCKS_IN_QUEUE_UNTIL_BLOCK 
                     // are waiting to be written
                     // This prevents an OutOfMemoryException
    ...
 }

 class DataConsumer implements Runnable {
   ...
   try {
       while(true) {
           writeData(queue.take()); // blocks until there is a block of data
       }
   } catch (InteruptedException e) {
       Thread.currentThread().interrupt();
   }
   ...
 }
于 2011-01-15T19:46:12.413 回答
1

您可以拥有一个锁数组，例如 32，并使用块的索引作为哈希来确定要获取哪个锁。这样，您可以（大部分时间）进行并发读/写，并且仍然确保您不会在多个线程中读/写同一个块。

于 2011-01-15T19:36:06.957 回答