lxy/zhub-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改：延时时间数值类型为long

Browse Source
This commit is contained in:
lxy 2021-05-22 16:19:43 +08:00
parent eaa3e913f8
commit 1f23dbf3cd
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/com/zdemo/zhub/ZHubClient.java
View File

@ -361,8 +361,8 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
} }
// 发送 publish 主题消息，若多次发送的 topic + "-" + value 相同，将会做延时重置 // 发送 publish 主题消息，若多次发送的 topic + "-" + value 相同，将会做延时重置
public void delay(String topic, Object v, int delay) { public void delay(String topic, Object v, long millis) {
send("delay", topic, toStr(v), String.valueOf(delay)); send("delay", topic, toStr(v), String.valueOf(millis));
} }
// 表达式支持：d+[d,H,m,s] // 表达式支持：d+[d,H,m,s]

6
test/com/zdemo/test/AppTest.java
View File

@ -2,7 +2,6 @@ package com.zdemo.test;
import com.zdemo.Event; import com.zdemo.Event;
import com.zdemo.IProducer; import com.zdemo.IProducer;
import com.zdemo.zhub.Lock;
import org.junit.Test; import org.junit.Test;
import org.redkale.boot.Application; import org.redkale.boot.Application;
import org.redkale.convert.json.JsonConvert; import org.redkale.convert.json.JsonConvert;
@ -12,7 +11,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
import java.util.function.Function; import java.util.function.Function;
import java.util.logging.Logger; import java.util.logging.Logger;
@ -47,7 +45,7 @@ public class AppTest {
//consumer.delay("a", "1", 200); //consumer.delay("a", "1", 200);
consumer.delay("a", "1", "2000");*/ consumer.delay("a", "1", "2000");*/
Consumer<String> con = x -> { /*Consumer<String> con = x -> {
logger.info("--->开始申请锁:" + System.currentTimeMillis()); logger.info("--->开始申请锁:" + System.currentTimeMillis());
Lock lock = consumer.tryLock("a", 20); Lock lock = consumer.tryLock("a", 20);
logger.info("===>成功申请锁:" + System.currentTimeMillis()); logger.info("===>成功申请锁:" + System.currentTimeMillis());
@ -64,7 +62,7 @@ public class AppTest {
new Thread(() -> con.accept("x")).start(); new Thread(() -> con.accept("x")).start();
new Thread(() -> con.accept("y")).start(); new Thread(() -> con.accept("y")).start();
new Thread(() -> con.accept("z")).start(); new Thread(() -> con.accept("z")).start();*/
Thread.sleep(60_000 * 60); Thread.sleep(60_000 * 60);