Skip to content

Commit e12bd38

Browse files
committed
Modernize
1 parent 605ac12 commit e12bd38

File tree

1 file changed

+9
-12
lines changed

1 file changed

+9
-12
lines changed

Tests/SQLiteTests/ConnectionTests.swift

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -382,31 +382,28 @@ class ConnectionTests : SQLiteTestCase {
382382
_ = DispatchQueue(label: "queue", qos: .background).asyncAfter(deadline: deadline, execute: db.interrupt)
383383
AssertThrows(try stmt.run())
384384
}
385-
385+
386386
func test_concurrent_access_single_connection() {
387-
let conn = try! Connection("\(NSTemporaryDirectory())/SQLite.swift Connection Tests.sqlite")
387+
let conn = try! Connection("\(NSTemporaryDirectory())/\(UUID().uuidString)")
388388
try! conn.execute("DROP TABLE IF EXISTS test; CREATE TABLE test(value);")
389389
try! conn.run("INSERT INTO test(value) VALUES(?)", 0)
390-
391-
let q = dispatch_queue_create("Readers", DISPATCH_QUEUE_CONCURRENT);
392-
393-
var reads = [0, 0, 0, 0, 0]
390+
let queue = DispatchQueue(label: "Readers", attributes: [.concurrent])
391+
let nReaders = 5
392+
var reads = Array(repeating: 0, count: nReaders)
394393
var finished = false
395-
for index in 0..<5 {
396-
dispatch_async(q) {
394+
for index in 0..<nReaders {
395+
queue.async {
397396
while !finished {
398-
_ = try! conn.prepare("SELECT value FROM test")
397+
_ = try! conn.scalar("SELECT value FROM test")
399398
reads[index] += 1
400399
}
401400
}
402401
}
403-
404402
while !finished {
405403
sleep(1)
406404
finished = reads.reduce(true) { $0 && ($1 > 500) }
407405
}
408-
}
409-
406+
}
410407
}
411408

412409

0 commit comments

Comments
 (0)