我在这里遇到某种问题。我正在开发一个读取文件并在UITableView中显示其内容的应用程序。最近我意识到文件可能会变得很大,并且我需要对文件的实际读取进行异步编码。我的项目已经很大,今天我设法将我已经在NSOperation中拥有的代码包装起来。

我所做的是现在在NSOperation中调用了我的解析器(打开和读取文件)。就像这样:

@implementation ReadPcapOperation

@synthesize parser =_parser;

- (id) initWithURL:(NSURL *)url linkedTo:(PacketFlowViewController *)packetController
{
    self = [super init];
    if (self) {
        _parser = [[PcapParser alloc] initWithURL:url linkedTo:packetController];
    }
    return self;
}

- (void)main {
    // a lengthy operation
    @autoreleasepool {
        if (self.isCancelled)
            return;

        [_parser read];

    }
}

@end


我这里只给您实现,.h文件中没有什么重要的。这个NSOperation子类在NSOperation中被调用:

_queue = [NSOperationQueue new];
_queue.name = @"File Parsing Queue";
_queue.maxConcurrentOperationCount = 1;
[_queue addOperation:_readFileOperation];


_readFileOperation是上述ReadPcapOperation的实例。

现在,当我测试我的代码时,仍然没有区别,当我打开文件时,在文件内容加载到我的UITableView中时,UI仍然被阻止。我测试了这种情况:

[NSThread isMainThread]


该测试从ReadPcapOperation的main中返回NO,这很好,正是我所需要的。但是,当我将它放入方法“ read”(从ReadPcapOperation发送到main内部的对象的消息)中时,此测试返回YES!因此,我的整个代码仍在主线程上运行,并阻塞了UI。

伙计们,我在这里想念什么?

让我知道您是否需要更多说明!

编辑:

这是很奇怪的事情:我将发布一部分代码,该代码本应在后台线程中执行。

- (void) read
{
    if ([NSThread isMainThread])
        NSLog(@"read: IT S MAIN THREAD");
    else
        NSLog(@"read: IT S NOT MAIN THREAD");

    [_fileStream open];
}

- (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode {
    switch(eventCode)
    {
        case NSStreamEventOpenCompleted:
        {
            //We read the pcap file header
            [self readGlobalHeader];
            [self readNextPacket];
            break;
        }
        case NSStreamEventHasBytesAvailable:
        {
            //We read all packets
            [self readNextPacket];
            break;
        }
        case NSStreamEventNone:
        {
            break;
        }
        case NSStreamEventHasSpaceAvailable:
        {
            break;
        }
        case NSStreamEventEndEncountered:
        {
            NSLog(@"End encountered !");
            [_fileStream close];
            [_fileStream removeFromRunLoop:[NSRunLoop currentRunLoop]
                              forMode:NSDefaultRunLoopMode];
            //_fileStream = nil;
            break;
        }
        case NSStreamEventErrorOccurred:
        {
            NSError *theError = [stream streamError];
            NSLog(@"Error %i stream event occured. Domain : %@.", theError.code, theError.domain);
            [stream close];
            break;
        }
    }
}

- (void) readGlobalHeader
{
    if ([NSThread isMainThread])
        NSLog(@"readGlobalHeader: IT S MAIN THREAD");
    else
        NSLog(@"readGlobalHeader: IT S NOT MAIN THREAD");
    int sizeOfGlobalHeader = 24;


在这里,您可以看到我直接从NSOperation调用的方法。那里的日志显示:“不是主要线程”。到目前为止,一切都很好。读取打开NSInputStreamObject,然后委托将调用“ handleEvent”,并且此时我读取字节。当我调用“ readGlobalHeader”并读取文件的第一个字节时,日志为“ MAIN THREAD”。它也不应该在后台线程中吗?我真的迷路了!

可能需要注意的重要一点是,在初始化流时,在校准“读取”之前,我使用以下代码行对其进行了设置(我不确定这是原因所在):

[_fileStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];


编辑2:
这是断点之后的回溯。行为就像我上面描述的那样。
 (没有足够的声誉来发布图像)

Breakpoint at the read method
Breakpoint after the stream is open

最佳答案

很大程度上重申其他答案:将这样的NSOperation与流API一起使用是错误的。它们对于无数计算绑定任务最有用。诸如文件或网络I / O之类的事情大多涉及等待,并使用涉及完成块或委托和回调方法的异步API。

我似乎记得NSOperation文档没有提到太多,但是使用异步API时它们通常毫无意义。 (除了Rory O'Bryan所述,当使用“并发”操作时。但是,对于那些没有利用操作队列的后台线程性质的操作,只有它们的操作管理和依赖关系,即,如果只有一个操作,则无用)

发生的情况是您的[_fileStream open]方法中的read在操作队列中正在运行,然后迅速返回,并且操作完成。 stream:handleEvent:委托回调不在open中调用,而是在返回后的一段时间内调用。在主线程上调用它们的方式与您的代码未使用NSOperation的方式相同。

morningstar的答案不同,我假设您确实需要使用流API(如果不是,则他的答案有效-转换为同步调用,并且您的操作应按预期进行)。

我说你应该回到不使用NSOperation的意义上-它没有给你买任何东西。如果您喜欢_fileStream业务如何封装在操作对象中,请将您的操作对象转换为普通的NSObject子类,然后调用其read方法。

查看您的readGlobalHeaderreadNextPacket方法。他们可能正在进行同步调用,这肯定是阻塞主线程的原因。如果确实如此,那么您可以选择以下几种方法:


遵循Ramy Al Zuhouri的建议,但使用dispatch_async代替将调用包装到readNextPacket等方法中。从理论上讲,您可以按照他的明确示例进行操作,也可以对[_fileStream open]进行操作,但是只有在您认为此调用需要很长时间才能返回时,我才这样做。 GCD是一种使这些方法在后台线程中运行的简单方法,只需仔细阅读即可正确设置队列即可。
Rory O'Bryan建议的那样,更改流调度,以便在创建的线程中调用委托方法。创建线程和运行循环可能很棘手,但是this example似乎显示了一种简便的方法,尽管可能不是最好的方法。您必须至少添加一些内容才能停止线程。

我认为最好的顺序应该是:


th = [[NSThread alloc] init...]
[_fileStream scheduleInRunLoop:<thread's-runloop> ...]
[th start]
线程方法仅调用一次[[NSRunLoop currentRunLoop] run]


然后,当流关闭时,它将自己从runloop中取消调度,然后运行方法返回,因此线程的方法返回,并且线程结束。请注意,尽管我可能是错的,但毕竟您可能需要将[[NSRunLoop currentRunLoop] run]放入循环中。
转换readNextPacket等以使用异步API。我想这可能最有意义,除非您正在这些方法中进行大量计算,而不仅仅是网络I / O。

关于ios - 在具有NSOperation的NSOperationQueue中运行并行代码,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/16921906/

10-13 03:59