如何通知一个线程等待下载完成，然后将数据传递给等待线程 [英] How can I signal one thread to wait until a download is finished and after that pass the data to waiting thread

问题描述

我有一个单例类可以从网上下载一些数据。我从GCD队列中的其他类'A'调用单例类的下载方法，并开始下载。同时我也从GCD队列中的类'B'执行此下载方法。在这种情况下，我想通知班级'B'等待下载完成。下载完成后，还将下载数据的副本提供给B类。在这里，我试图从两个类A和B下载相同的文件，否则我的实现没有问题。怎么可能？

I have a singleton class to download some data from the web. I am calling the download method of the singleton class from other class 'A' inside a GCD Queue and the downloads starts. The same time I am also executing this download method from a class 'B' in a GCD Queue. In this situation I want to inform the Class 'B' to wait until the download is completed. And when the download is completed give a copy of the downloaded data to class 'B' also. Here I am trying to download the same file from two classes A and B, otherwise there is no problem in my implementation. How is it possible?

这意味着我在不同的线程中调用相同的方法。那么如何向线程B发出信号，告知线程A中正在进行相同的文件下载，并在完成时将数据传递给线程B

Means here I am calling the same method in different threads. So how can I signal the thread B that the same file download is in progress in thread A and when finished pass the data to thread B also

- (NSData *)Download:(NSString *)urlString{

     // here I am doing all the downloading operations
     return data;
}

推荐答案

Downloader.h

Downloader.h

// Signature of a block that is called with the downloaded data from a URL
// when the download is complete
typedef (void)(^)(NSData *) DownloadCompletedBlock;

// Public interface of a class that downloads data from URLs
// Downloads take place on a private dispatch queue, which
// downloads URLs one at a time
// Previously downloaded URLs are cached in a dictionary
// Every so often the cache should be processed to discard old
// entries. This will stop the cache from growing too large.
// Since all downloads happen on the same dispatch queue,
// accesses to the cache are naturally serialized without the need
// for a lock
@interface Downloader : NSObject

// Download the contents of a URL
// When the download is complete downloadCompleted will
// be executed on the callbackQueue to pass the downloaded
// data as a result
// This is the method that thread A should call
- (void)download:(NSString *)URLString 
    calbackQueue:(dispatch_queue_t)callbackQueue
 completionBlock:(DownloadCompletedBlock)downloadCompleted;

// Download the contents of a URL blocking the thread that calls the
// method
- (NSData *)downloadBlocking:(NSString *)URLString;

@end

Downloader.m

Downloader.m

// Private implementation interface
@interface Downloader ()

// The thread/queue on which all downloads take place
@property (readwrite, atomic) dispatch_queue_t downloadQueue;
// A cache of previously downloaded URLs
@property (readwrite, atomic) NSMutableDictionary *cachedDownloads;

// Download the contents of a URL and cache them
- (NSData *)downloadAndCacheUrl:(NSString *)URLString;

@end

// Implementation
@implementation Downloader

// Create the download queue and cache
- (id)init {
  self = [super init];
  if (self) {
    downloadQueue = dispatch_queue_create("downloadQueue", NULL);
    self.cachedDownloads = [NSMutableDictionary dictionary];
  }
  return self;
}

// Download the URL aynchronously on the download queue.
// When the download completes pass the result to the callback queue
// by calling downloadCompleted on the callback queue
- (void)download:(NSString *)URLString 
    calbackQueue:(dispatch_queue_t)callbackQueue
 completionBlock:(DownloadCompletedBlock)downloadCompleted {
  dispatch_async(self.downloadQueue, ^{
    NSData *downloadedData = [self downloadAndCacheUrl:URLString];
    dispatch_async(callbackQueue, ^{
      downloadCompleted(downloadedData);
    });
  });
}

// Download the data blocking the calling thread
// Use a block variable to store the result
// Since the downloaded data is immutable, we do not need
// to worry about synchronizing it or copying it
// Use dispatch_sync to wait until the result is available
// If the data is already in the cache because thread A downloaded it
// then the cached data is used.
// Since downloads happen serially, there is only ever one download happening
// at a time so the download will only happen once
- (NSData *)downloadBlocking:(NSString *)URLString {
  __block NSData *downloadedData = nil;
  dispatch_sync(self.downloadQueue, ^{
    downloadedData = [self downloadAndCacheUrl:URLString];
  });
  return downloadedData;
}

// Download the content of a URL. If the data has already been
// downloaded and cached, then use the cached value
- (NSData *)downloadAndCacheUrl:(NSString *)URLString {
  NSURL *URL = [NSURL URLWithString:*)URLString];
  NSData *downloadedData = [self.cachedDownloads objectForKey:URL];
  if (downloadedData) {
    return downloadedData;
  }
  downloadedData = [NSData dataWithContentsOfURL:URL];
  if (downloadedData) {
    [self.cachedDownloads setObject:downloadedData forKey:URL];
  }
}

@end

希望这很清楚

这篇关于如何通知一个线程等待下载完成，然后将数据传递给等待线程的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！