Objective-Cに相当するJavaのBlockingQueue？

Question

私はJava開発を長年してiPhone開発に取り掛かりつつあります。私はJavaのBlockingQueueに相当するObjective-Cを探しています。そんなことはありますか？

私は物事を間違った道を進んだ場合は、ここで私が達成しようとしているものです：

私は、ネットワークサーバからプルデータのチャンクを一度に表示します。ユーザーがネットワークの遅れに気付かないように、私はいつもデータのプリフェッチをいくつかしたいと思っています。 Javaの土地では、私のフェッチスレッドと私の表示スレッドの間にスレッドセーフキューを使用したいと思います。

Answer 1

NSOperationをスピンオフして、データが戻ってきたときに通知をポストすることができます。 NSURLConnectionセッションをカプセル化する方法を示しNSOperationとの同時実行上のデイブDribinのブログ記事を見てみましょう：

http://www.dribin.org/dave/blog/archives/2009/05/05/concurrent_operations/

あなたはNSURLConnectionが適切であるWebサービスやサイトへのアクセスについて話されていない場合は、代わりにすることができますそれはまっすぐにTCP/IPまたはUDPかどうココア非同期ソケットを使用します。

http://code.google.com/p/cocoaasyncsocket/

よろしく、

Answer 2

このようなことはネイティブにはありません。おそらくネットワークオブジェクトのキューを管理する独自のクラスを作成する必要があります。 （そして、あなたはobjects配列から最上位オブジェクトをポップして返すようにgetNextChunkを実装し、[objects count]が一定値未満であれば、いくつかのより多くのオブジェクトをフェッチするスレッドを起動することができ

@interface ObjcBlockingQueue : NSObject { 
    // The objects that you're holding onto 
    NSArray *objects; 
} 

@property(nonatomic,retain) NSArray *objects; 

- (ServerData *)getNextChunk;

：あなたのヘッダーは次のようになりますおそらくObjcBlockingQueueがデリゲートであるNSURLConnectionを使用しています）。キューを事前に埋め込むために、オーバーライドされたinitメソッドの中で起動されたそのスレッド/接続を持つこともできます。

また、あなたの表示スレッドは、それがすぐに何か新しいものを表示することができますか、それはロードメッセージを表示する必要がある場合かどうかをお知らせします

- (BOOL)isChunkAvailable;

メソッドを追加することについて考えたいかもしれません。データを表示する場所やアプリケーションの構造によっては、ObjcBlockingQueueをシングルトンクラスにする価値があります。

Answer 3

はここimplemenですキューとデキューメソッドを使用したブロッキングキューの作成。 1つのスレッドがdequeueUnitOfWorkWaitingUntilDate：を呼び出すループに入り、2つ目のスレッドがqueueUnitOfWork：を呼び出している間に作業単位を処理することが期待されます。

@interface MyBlockingQueue : NSObject { 
    NSMutableArray *queue; 
    NSConditionLock *queueLock; 
} 
- (id)dequeueUnitOfWorkWaitingUntilDate:(NSDate *)timeoutData; 
- (void)queueUnitOfWork:(id)unitOfWork; 
@end 

enum { 
    kNoWorkQueued = 0, 
    kWorkQueued = 1 
} 

@implementation MyBlockingQueue 
- (id)init { 
    if ((self = [super init])) { 
     queueLock = [[NSConditionLock alloc] initWithCondition:kNoWorkQueued]; 
     workItems = [[NSMutableArray alloc] init]; 
    } 
    return self; 
} 

- (void)dealloc { 
    [queueLock release]; 
    [workItems release]; 
    [super dealloc]; 
} 

- (id)dequeueUnitOfWorkWaitingUntilDate:(NSDate *)timeoutDate { 
    id unitOfWork = nil; 
    if ([queueLock lockWhenCondition:kWorkQueued beforeDate:timeoutDate]) { 
     unitOfWork = [[[queue objectAtIndex:0] retain] autorelease]; 
     [queue removeObjectAtIndex:0]; 
     [queueLock unlockWithCondition:([workItems count] ? kWorkQueued : kNoWorkQueued)]; 
    } 
    return unitOfWork; 
} 

- (void)queueUnitOfWork:(id)unitOfWork { 
    [queueLock lock]; 
    [queue addObject:unitOfWork]; 
    [queueLock unlockWithCondition:kWorkQueued]; 
} 
@end