FilesExpand file tree

 master

/

RehashFuture.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

46 lines (39 loc) · 1.5 KB

 master

/

RehashFuture.java

Top

File metadata and controls

• Code
• Blame

46 lines (39 loc) · 1.5 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

package RedisFuture;

import Common.Logger;

import RedisDataBase.RedisDict;

import RedisServer.RedisServer;

import java.util.concurrent.Future;

/*用来执行RedisMap Rehash完成之后的回调*/

public class RehashFuture implements RedisFuture {

private RedisDict dict;

boolean holdIsDecremented = false;// 用来判断dict是不是已经执行了decrementHold()

public Future future;

public RehashFuture(RedisDict dict,Future future){

this.dict = dict;

this.future = future;

}

public void onComplete(){

try{

if(holdIsDecremented == false){

holdIsDecremented = true;

dict.decrementHold();

assert (dict.inConcurrent());//这个时候可以确定是inConcurrent()的,如果resubmit了就不一定了

}

// 只有在主线程持有唯一引用的时候执行stoRehash才是线程安全的

if(dict.holdByOther()){

// 重新提交自己

RedisServer.addFuture(this);

System.out.println("resubmit itself when stopRehash");

}else{

dict.stopRehash();// rehash完成了

System.out.println("结束啦,当前状态 len:" + dict.length() + "size:"+ dict.size() );

}

} catch (Exception e) {

Logger.debug(e.getStackTrace().toString());

}

}

public boolean isDone(){

return future.isDone();

}

public void get() throws Exception {future.get();}

}