Как реализовать рабочую очередь в iOS, где обрабатывается только самый новый запрос?
В моей программе для iOS происходит следующее: когда пользователь вводит текст, запрос отправляется в поток, в котором инициируется поиск в базе данных. Когда поиск в БД завершен, в главном потоке запускается ответ, поэтому приложение может отображать результаты.
Это прекрасно работает, за исключением того, что если пользователь набирает очень быстро, может быть несколько запросов в полете. Со временем система наверстает упущенное, но это кажется неэффективным.
Есть ли удобный способ реализовать его так, чтобы, если запрос инициирован, я мог обнаружить, что поиск уже выполняется, и вместо этого запрос должен быть сохранен как «потенциально новый, который превосходит один в полете»?
РЕШЕНИЕ ОБРАЗЦА С КОММЕНТАРИИ, ДОБАВЛЕННЫЕ НИЖЕ
Вот тело контроллера представления для небольшого примера проекта, который иллюстрирует свойства решения. При наборе вы можете получить такой результат:
2012-11-11 11:50:20.595 TestNsOperation[1168:c07] Queueing with 'd'
2012-11-11 11:50:20.899 TestNsOperation[1168:c07] Queueing with 'de'
2012-11-11 11:50:21.147 TestNsOperation[1168:c07] Queueing with 'det'
2012-11-11 11:50:21.371 TestNsOperation[1168:c07] Queueing with 'dett'
2012-11-11 11:50:21.599 TestNsOperation[1168:1b03] Skipped as out of date with 'd'
2012-11-11 11:50:22.605 TestNsOperation[1168:c07] Up to date with 'dett'
В этом случае первая операция в очереди будет пропущена, поскольку она определяет, что она устарела при выполнении длительной части своей работы. Две следующие операции в очереди ('de' и 'det') отменяются еще до того, как им разрешено выполнять. Последняя заключительная операция - единственная, которая фактически заканчивает всю свою работу.
Если вы закомментируете строку [self.lookupQueue cancelAllOperations], вы получите следующее поведение:
2012-11-11 11:55:56.454 TestNsOperation[1221:c07] Queueing with 'd'
2012-11-11 11:55:56.517 TestNsOperation[1221:c07] Queueing with 'de'
2012-11-11 11:55:56.668 TestNsOperation[1221:c07] Queueing with 'det'
2012-11-11 11:55:56.818 TestNsOperation[1221:c07] Queueing with 'dett'
2012-11-11 11:55:56.868 TestNsOperation[1221:c07] Queueing with 'dette'
2012-11-11 11:55:57.458 TestNsOperation[1221:1c03] Skipped as out of date with 'd'
2012-11-11 11:55:58.461 TestNsOperation[1221:4303] Skipped as out of date with 'de'
2012-11-11 11:55:59.464 TestNsOperation[1221:1c03] Skipped as out of date with 'det'
2012-11-11 11:56:00.467 TestNsOperation[1221:4303] Skipped as out of date with 'dett'
2012-11-11 11:56:01.470 TestNsOperation[1221:c07] Up to date with 'dette'
В этом случае все операции в очереди будут выполнять часть длины своей работы, даже если более новая операция была помещена в очередь после нее еще до того, как она была запланирована для выполнения.
@interface SGPTViewController ()
@property (nonatomic, strong) NSString* oldText;
@property (strong) NSOperationQueue *lookupQueue;
@end
@implementation SGPTViewController
- (void)viewDidLoad
{
[super viewDidLoad];
// Do any additional setup after loading the view, typically from a nib.
self.oldText = self.source.text;
self.lookupQueue = [[NSOperationQueue alloc] init];
self.lookupQueue.maxConcurrentOperationCount = 1;
}
- (void)textViewDidChange:(UITextView *)textView
{
// avoid having a strong reference to self in the operation queue
SGPTViewController * __weak blockSelf = self;
// you can cancel existing operations here if you want
[self.lookupQueue cancelAllOperations];
NSString *outsideTextAsItWasWhenStarted = [NSString stringWithString:self.source.text];
NSLog(@"Queueing with '%@'", outsideTextAsItWasWhenStarted);
[self.lookupQueue addOperationWithBlock:^{
// do stuff
NSString *textAsItWasWhenStarted = [NSString stringWithString:outsideTextAsItWasWhenStarted];
[NSThread sleepForTimeInterval:1.0];
if (blockSelf.lookupQueue.operationCount == 1) {
// do more stuff if there is only one operation on the queue,
// i.e. this one. Operations are removed when they are completed or cancelled.
// I should be canceled or up to date at this stage
dispatch_sync(dispatch_get_main_queue(), ^{
if (![textAsItWasWhenStarted isEqualToString:self.source.text]) {
NSLog(@"NOT up to date with '%@'", textAsItWasWhenStarted);
} else {
NSLog(@"Up to date with '%@'", textAsItWasWhenStarted);
}
});
} else {
NSLog(@"Skipped as out of date with '%@'", textAsItWasWhenStarted);
}
}];
}