Commit 1b2d648

committed

Add test for single connection across multiple threads.

1 parent 0997f34 commit 1b2d648Copy full SHA for 1b2d648

File tree

+21

-0

lines changed

+21

-0

lines changed

Lines changed: 21 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -313,5 +313,26 @@ class ConnectionTests : SQLiteTestCase {`
`313`	`313`	`dispatch_after(dispatch_time(DISPATCH_TIME_NOW, Int64(10 * NSEC_PER_MSEC)), dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0), db.interrupt)`
`314`	`314`	`AssertThrows(try stmt.run())`
`315`	`315`	`}`
	`316`	`+`
	`317`	`+ func test_concurrent_access_single_connection() {`
	`318`	`+ let conn = try! Connection("\(NSTemporaryDirectory())/SQLite.swift Connection Tests.sqlite")`
	`319`	`+ try! conn.execute("DROP TABLE IF EXISTS test; CREATE TABLE test(value);")`
	`320`	`+ try! conn.run("INSERT INTO test(value) VALUES(?)", 0)`
	`321`	`+`
	`322`	`+ let q = dispatch_queue_create("Readers", DISPATCH_QUEUE_CONCURRENT);`
	`323`	`+ var finished = false`
	`324`	`+`
	`325`	`+ for _ in 0..<100 {`
	`326`	`+ dispatch_async(q) {`
	`327`	`+ while !finished {`
	`328`	`+ _ = try! conn.prepare("SELECT value FROM test")`
	`329`	`+ }`
	`330`	`+ }`
	`331`	`+ }`
	`332`	`+`
	`333`	`+ // Give the threads some time to conflict`
	`334`	`+ sleep(5)`
	`335`	`+ finished = true`
	`336`	`+ }`
`316`	`337`
`317`	`338`	`}`

Comments

(0)