本文整理了Java中scouter.util.Queue.size
方法的一些代码示例,展示了Queue.size
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.size
方法的具体详情如下:
包路径:scouter.util.Queue
类名称:Queue
方法名:size
暂无
代码示例来源:origin: scouter-project/scouter
public int getQueueSize() {
return queue.size();
}
代码示例来源:origin: scouter-project/scouter
public boolean isQueueOk() {
return queue.size() < 1000;
}
代码示例来源:origin: scouter-project/scouter
public int getQueueSize() {
return queue.size();
}
代码示例来源:origin: scouter-project/scouter
public boolean isQueueOk() {
return queue.size() < 1000;
}
代码示例来源:origin: scouter-project/scouter
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: scouter-project/scouter
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: scouter-project/scouter
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: scouter-project/scouter
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: scouter-project/scouter
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: scouter-project/scouter
public void run() {
DataUdpAgent udp = DataUdpAgent.getInstance();
while (running) {
int size = queue.size();
switch (size) {
case 0:
ThreadUtil.sleep(conf.net_udp_collection_interval_ms);
break;
case 1:
udp.write(queue.pop());
break;
default:
send(udp, size);
break;
}
}
}
代码示例来源:origin: scouter-project/scouter
public void run() {
DataUdpAgent udp = DataUdpAgent.getInstance();
while (running) {
int size = queue.size();
switch (size) {
case 0:
ThreadUtil.sleep(conf.net_udp_collection_interval_ms);
break;
case 1:
udp.write(queue.pop());
break;
default:
send(udp, size);
break;
}
}
}
代码示例来源:origin: io.github.scouter-project/zipkin-storage-scouter-udp
public int getQueueSize() {
return queue.size();
}
代码示例来源:origin: io.github.scouter-project/scouter-agent-java
public boolean isQueueOk() {
return queue.size() < 1000;
}
代码示例来源:origin: io.github.scouter-project/zipkin-storage-scouter-udp
public boolean isQueueOk() {
return queue.size() < 1000;
}
代码示例来源:origin: io.github.scouter-project/scouter-agent-java
public int getQueueSize() {
return queue.size();
}
代码示例来源:origin: io.github.scouter-project/scouter-server
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: io.github.scouter-project/scouter-common
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: io.github.scouter-project/scouter-agent-java
public static void main(String[] args) {
Integer v;
Queue<Integer> q = new Queue<Integer>(4);
q.push(1);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
q.push(2);
System.out.println("full ? " + q.isFull());
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
print("out = ", q.pop(q.size()));
}
代码示例来源:origin: io.github.scouter-project/scouter-agent-java
public void run() {
DataUdpAgent udp = DataUdpAgent.getInstance();
while (running) {
int size = queue.size();
switch (size) {
case 0:
ThreadUtil.sleep(conf.net_udp_collection_interval_ms);
break;
case 1:
udp.write(queue.pop());
break;
default:
send(udp, size);
break;
}
}
}
代码示例来源:origin: io.github.scouter-project/zipkin-storage-scouter-udp
public void run() {
DataUdpAgent udp = DataUdpAgent.getInstance();
while (running) {
int size = queue.size();
switch (size) {
case 0:
ThreadUtil.sleep(100);
break;
case 1:
udp.write(queue.pop());
break;
default:
send(udp, size);
break;
}
}
}
内容来源于网络,如有侵权,请联系作者删除!