Jak zaimplementować kolejkę pracy w systemie iOS, gdzie obsługiwane jest tylko najnowsze żądanie?
W moim programie iOS zachodzi następująca sytuacja: Podczas wpisywania przez użytkownika żądanie jest wysyłane do wątku, w którym inicjowane jest wyszukiwanie bazy danych. Po zakończeniu wyszukiwania bazy danych w głównym wątku odpalana jest odpowiedź, dzięki czemu aplikacja może wyświetlać wyniki.
Działa to świetnie, z wyjątkiem tego, że jeśli użytkownik wpisze naprawdę szybko, może być kilka żądań w locie. Ostatecznie system nadrobi zaległości, ale wydaje się nieefektywny.
Czy istnieje dobry sposób na zaimplementowanie go tak, że jeśli żądanie zostanie zainicjowane, mogę wykryć, że wyszukiwanie jest już w toku, a zamiast tego żądanie powinno być przechowywane jako „potencjalnie najnowszy, który przewyższa ten w locie”?
PRZYKŁADOWE ROZWIĄZANIE Z DODATKOWYMI UWAGAMI PONIŻEJ
Oto treść kontrolera widoku dla małego przykładowego projektu, który ilustruje właściwości rozwiązania. Podczas pisania możesz uzyskać następujące dane wyjściowe:
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'
W tym przypadku pierwsza operacja kolejkowania jest pomijana, ponieważ określa, że stała się nieaktualna podczas wykonywania dłuższej części swojej pracy. Dwie następujące kolejkowane operacje („de” i „det”) są anulowane, zanim będą mogły wykonywać. Ostateczna operacja końcowa jest jedyną, która faktycznie kończy wszystkie prace.
Jeśli komentujesz linię [self.lookupQueue cancelAllOperations], otrzymasz to zachowanie:
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'
W tym przypadku cała kolejkowana operacja wykona część długości ich pracy, nawet jeśli nowsza operacja została skolejkowana po niej, zanim jeszcze została zaplanowana do wykonania.
@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);
}
}];
}