zoukankan      html  css  js  c++  java
  • CoreData和SQLite多线程访问时的线程安全问题

    数据库读取操作一般都是多线程访问的。在对数据进行读取时,我们要保证其当前状态不能被修改,即读取时加锁,否则就会出现数据错误混乱。
    IOS中常用的两种数据持久化存储方式:CoreData和SQLite,两者都需要设置线程安全,在这里以FMDB来解释对SQLite的线程安全访问。

    一:FMDB的线程安全:(以读取图片为例)

    1.没有线程安全的执行方式:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    //************** 数据库保存图片  ******************//
     
     FMDatabase *database = [FMDatabase databaseWithPath:[self getDatabasePath]];
     
     //打开数据库
     
     [database open];
     
     NSString *sql = @"create table if not exists Test (id integer primary key autoincrement,name text,image blob);";
     
     //创建表
     
     [database executeUpdate:sql];
     
     //把UIImage对象转化为NSData
     
     NSData *data = UIImagePNGRepresentation([UIImage imageNamed:@"user_browse"]);   
     
     //写入数据
     
     sql = @"insert into Test (name,image) values (?,?)";
     
     [database executeUpdate:sql,@"张三",data];
     
     //读取显示
     
     sql = @"select * from Test;";
     
     FMResultSet *resultSet = [database executeQuery:sql];
     
     while (resultSet.next)
     
     {
     
         //[resultSet dataForColumn:@"image"];
     
         NSData *imageData = [resultSet dataForColumnIndex:2];
     
         UIImageView *imageView = [[UIImageView alloc] initWithFrame:CGRectMake(0, 0, 300, 300)];
     
         imageView.image = [UIImage imageWithData:imageData];
     
         [self.view addSubview:imageView];
     
     }

      2,使用线程队列

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    //************** 数据库线程安全 ***********//
        FMDatabaseQueue *queue = [[FMDatabaseQueue alloc] initWithPath:[self getDatabasePath]];
     
        [queue inDatabase:^(FMDatabase *db) {
     
            //线程安全的
     
            __block NSString *sql = @"create table if not exists Test (id integer primary key autoincrement,name text,image blob);";
     
            //创建表
     
            [database executeUpdate:sql];
     
        }];
     
        //插入数据
     
        [queue inDatabase:^(FMDatabase *db) {
     
            //写入数据
     
            sql = @"insert into Test (name,image) values (?,?)";
     
            [database executeUpdate:sql,@"张三",data];
     
        }];
     
        //读取
        [queue inDatabase:^(FMDatabase *db) {
            //读取显示
            sql = @"select * from Test;";
            FMResultSet *resultSet = [database executeQuery:sql];
            while (resultSet.next)
            {
                //[resultSet dataForColumn:@"image"];
     
                NSData *imageData = [resultSet dataForColumnIndex:2];
                UIImageView *imageView = [[UIImageView alloc] initWithFrame:CGRectMake(0, 0, 300, 300)];
     
                imageView.image = [UIImage imageWithData:imageData];
                [self.view addSubview:imageView];
            }
        }];

      分析一下线程安全下的FMDB的实现:
    在当使用FMDBDatabaseQueue创建数据库时,会使用GCD创建一个线程队列:

    1
    2
    3
    4
    5
    。。。
     _queue = dispatch_queue_create([[NSString stringWithFormat:@"fmdb.%@"self] UTF8String], NULL);
            dispatch_queue_set_specific(_queue, kDispatchQueueSpecificKey, (__bridge void *)selfNULL);
            _openFlags = openFlags;
    。。。

      然后在读取时调用[queue inDatabase:^(FMDatabase *db)方法,在block中会锁定当前数据库

    1
    2
    3
    4
    5
    dispatch_sync(_queue, ^() {
            FMDatabase *db = [self database];
            block(db);
        ……
    }

      我们可以看到实际上这里是对整个数据库进行加锁,以此来保证线程安全的。

    二、CoreData的线程安全

    1.没有线程安全的coredata数据读取:

    NSManagedObjectContext对象的创建:_managedObjectContext = [[NSManagedObjectContext alloc] init];

    插入数据操作:(AppDetailModal为数据模型)

    context 为返回的 _managedObjectContext

    1
    AppDetailModal *newapp = [NSEntityDescription insertNewObjectForEntityForName:TableName inManagedObjectContext:context];

    其他查询、更新、删除操作
    //获取Entity

    1
    NSEntityDescription *entity = [NSEntityDescription entityForName:TableName inManagedObjectContext:context];

      

    2.线程安全的coreData操作:

    首先创建并行的NSManagedObjectContext对象

    1
    NSManagedObjectContext* context=[[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];

      

    1
    2
    3
    4
    5
    然后在执行读取操作时使用一下两个方法:
     
    -(void)performBlock:(void (^)(void))block
     
    -(void)performBlockAndWait:(void (^)(void))block

      

    1
    2
    3
    4
    5
    [context performBlock:^{
     
            //要执行的读取操作
     
     }];
  • 相关阅读:
    python学习的第六天数据类型及内置方法part2
    作业5
    Python学习第五天基本数据类型及内部方法part1
    周作业
    作业
    python学习第四天控制流程if、while、for
    作业
    python学习第三天基本数据类型、格式化输入输出、运算符。流程控制
    从排序数组中删除重复项
    D3.js 比例尺
  • 原文地址:https://www.cnblogs.com/graveliang/p/5818696.html
Copyright © 2011-2022 走看看