DelayQueue，网吧记时

Wangmin：

package com.mhm.delayQueue;import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;public class Wangmin implements Delayed {private int id;private String name;// 下机时间private long endtime;private TimeUnit timeUnit = TimeUnit.SECONDS;public int getId() {return this.id;}public String getName() {return this.name;}public Wangmin(int id, String name, long endtime) {this.id = id;this.name = name;this.endtime = endtime;}@Overridepublic int compareTo(Delayed arg0) {Wangmin wm = (Wangmin)arg0;long d = this.getDelay(this.timeUnit) - wm.getDelay(this.timeUnit);if (d > 0) {return 1;} else if (d == 0) {return 0;} else {return -1;}}@Overridepublic long getDelay(TimeUnit arg0) {// return unit.convert(submitTime - System.nanoTime(), TimeUnit.NANOSECONDS);long flag = this.endtime - System.currentTimeMillis();// System.out.println(this.name + ", " + flag);return flag;}
}

wangba:

package com.mhm.delayQueue;import java.util.concurrent.DelayQueue;import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;public class Wangba implements Runnable {private static final Logger logger = LogManager.getLogger("Wangba");private DelayQueue<Wangmin> wmQueye = new DelayQueue<Wangmin>();public boolean yinye = true;public void shangji(int id, String name, int money) {Wangmin wm = new Wangmin(id, name, 1000*money + System.currentTimeMillis());logger.debug(name + ", 上机" + money + "秒");this.wmQueye.add(wm);}public void xiaji(Wangmin wm) {logger.debug(wm.getName() + ", 下机");}@Overridepublic void run() {while(yinye) {Wangmin wm;try {// 会按排序取出元素wm = wmQueye.take();xiaji(wm);} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) {logger.debug("开始营业");Wangba wb = new Wangba();Thread shangwang = new Thread(wb);shangwang.start();wb.shangji(8, "444", 10);wb.shangji(10, "111", 1);wb.shangji(5, "222", 5);wb.shangji(20, "333", 2);}}

DelayQueue，网吧记时相关推荐

DelayQueue使用示例之KTV包厢记时
在学习Java 多线程并发开发过程中,了解到DelayQueue类的主要作用:是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走. ...
轻松搞定网吧记费管理系统
轻松搞定网吧记费管理系统美萍和万象已经是过去了,现在有出现一些新的网吧记费管理系统---punwin, 呵呵,在网上搜一下关于破解pubwin的方法,怎么样?是不是少之又少?我们这边新开了一家 ...
手机验证码倒记时函数
/*** 倒记时* @param {object} options 设置参数* @param.fresh_text {string} 倒计时结束要显示的文字,默认使用按钮最初的文字* @param.c ...
Atitit.播放系统的选片服务器，包厢记时系统的说明，教程，维护，故障排查手册p825...
Atitit.播放系统的选片服务器,包厢记时系统的说明,教程,维护,故障排查手册p825 1. 播放系统服务器方面的维护 2 1.1. 默认情况下,已经在系统的启动目录下增加了俩个启动项目 2 1. ...
电脑记时----千年虫
2019独角兽企业重金招聘Python工程师标准>>> 俗话说,山中无甲子,寒暑不知年.这讲的是记时对人类的重要性.时间对于计算机来说,尤为重要.首先,它是计算机活动的心脏,提供系统 ...
Atitit. 包厢记时系统的说明，教程，维护，故障排查手册v2 pb25.doc
Atitit. 包厢记时系统的说明,教程,维护,故障排查手册v2 pb25.doc 1. 服务器方面的维护1 1.1. 默认情况下,已经在系统的启动目录下增加了个启动项目1 1.2. 后台服务.保 ...
javaSE (十六）Randon、System类的方法(生成随机数、主动垃圾回收、终止jvm、对程序进行记时、System自带的复制数组的方法）
生成0到100之间的伪随机数主动运行垃圾回收器,相当于呼喊保洁阿姨非0就是异常终止jvm 对程序进行记时 System自带的复制数组的方法 1. 生成0到100之间的伪随机数2. 运行垃圾回收器, ...
在线秒表 - 在线计时器 - 在线记时器
在线秒表 - 在线计时器 - 在线记时器 https://www.online-stopwatch.com/ https://www.online-stopwatch.com/chinese/ 1. ...
仿热血江湖帮战客方血帮战准备记时器结束事件
public void timer_0_Elapsed(object sender, ElapsedEventArgs e) { if (GClass4.int ...

DelayQueue，网吧记时

DelayQueue，网吧记时相关推荐

最新文章

热门文章