FilesExpand file tree

 master

/

ExpireFuture.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

43 lines (34 loc) · 1.14 KB

 master

/

ExpireFuture.java

Top

File metadata and controls

• Code
• Blame

43 lines (34 loc) · 1.14 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

package RedisFuture;

import Common.Logger;

import RedisDataBase.ExpireObject;

import RedisDataBase.PriorityList;

import RedisDataBase.RedisDb;

import RedisDataBase.RedisTimerWheel;

import java.util.HashMap;

import java.util.PriorityQueue;

import java.util.concurrent.Future;

public class ExpireFuture implements RedisFuture{

public Future future;// 持有真正future的引用

int curIndex; // 持有的index

PriorityList[] expires;// 持有的hashMap

public ExpireFuture(int curIndex,PriorityList[] expires,Future future){

this.curIndex = curIndex;

this.expires = expires;

this.future = future;

}

// 注意到,toNormal必须要保证线程安全

public void onComplete(){

try{

RedisDb.RedisMap.toNormal();

RedisDb.ExpiresDict.toNormal();

RedisTimerWheel.convertTimerWheelToNormal(curIndex);

System.out.println("done ");

} catch (Exception e) {

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

}

}

public boolean isDone(){

return future.isDone();

}

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

}