最近在做一个Android项目， 为了改善用户体验，把原先必须让用户“等待”的过程改成在新线程中异步执行。但是这样做遇到了多个线程同时需要写Sqlite数据库，导致操作数据库失败。
本人对Java并不熟悉，只接触了2个多月（纯粹为了Android项目， 才开始接触JAVA）， 在网上搜了一下， 发现JAVA在线程同步方面提供的功能相对于C#真少，只找到synchronized关键字， 而且还不提供timeout机制， 不过经过测试， 至少解决了目前的需求。
问题需求：
1. Android中， 对Sqlite数据库操作， 需要自己实现一个继承自SQLiteOpenHelper的类
2. 实现类中， 对数据库read操作不需要同步(提高效率)
3. 实现类中， 所有对数据库写操作， 必须要同步
解决方法：
定义一个private final static byte[] _writeLock = new byte[0]; 作为写锁
static 保证多个实例之间， 使用的是同一个对象（同一把锁）
final 保证锁对象不会被修改
测试代码：
|
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
|
package
com.yushiro;
public
class
multiThreadTest {
private
final
static
byte
[] _writeLock =
new
byte
[
0
];
private
static
int
_syncInt =
0
;
public
void
Method1(){
synchronized
(_writeLock) {
StringBuffer sb =
new
StringBuffer();
sb.append(Thread.currentThread().getName());
sb.append(
" Method1 "
);
sb.append(_syncInt);
_syncInt++;
sb.append(
" --> "
);
sb.append(_syncInt);
System.out.println(sb.toString());
}
}
public
void
Method2(){
synchronized
(_writeLock) {
StringBuffer sb =
new
StringBuffer();
sb.append(Thread.currentThread().getName());
sb.append(
" Method2 "
);
sb.append(_syncInt);
_syncInt++;
sb.append(
" --> "
);
sb.append(_syncInt);
System.out.println(sb.toString()); }
}
public
void
Method3(){
synchronized
(_writeLock) {
this
.Method1();
this
.Method2();
}
}
}
|
|
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
package
com.yushiro;
public
class
MainTest {
public
static
void
main(String[] args) {
Thread t2=
new
Thread1();
Thread t1=
new
Thread2();
Thread t3 =
new
Thread3();
t1.start();
t2.start();
t3.start();
}
private
static
class
Thread2
extends
Thread {
public
void
run() {
multiThreadTest tmp =
new
multiThreadTest();
while
(
true
) {
try
{
Thread.sleep(
30000
);
tmp.Method1();
}
catch
(InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//System.out.println(y);
}
}
}
private
static
class
Thread1
extends
Thread {
public
void
run() {
multiThreadTest tmp =
new
multiThreadTest();
while
(
true
) {
try
{
Thread.sleep(
100
);
tmp.Method2();
Thread.sleep(
100
);
tmp.Method1();
}
catch
(InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//System.out.println(y);
}
}
}
private
static
class
Thread3
extends
Thread {
public
void
run() {
multiThreadTest tmp =
new
multiThreadTest();
while
(
true
) {
try
{
Thread.sleep(
100
);
tmp.Method3();
}
catch
(InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//System.out.println(y);
}
}
}
}
|
Method3()是为了测试自旋锁
参考：
京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有