欧美日韩国产码高清综合一区一区_ java 大量數據提交時(shí)，使用隊列定時(shí)提交思路的程序實(shí)現

思路如下：

一個(gè)隊列，提交的信息不斷的放入隊列；

每隔一段時(shí)間定時(shí)提交一次，不管隊列中元素是否達到預定的個(gè)數；

模擬程序的思路：

開(kāi)啟兩個(gè)線(xiàn)程，一個(gè)模擬數據提交；另一個(gè)模擬數據讀?。ㄈ〕鰜?lái)插入數據庫）；

代碼如下：

Thread1.java

[java] view plain copy

print?

package cn.zhangshibo.liaocheng.test;
import java.util.LinkedList;
import java.util.Queue;
import java.util.Random;
public class Thread1 extends Thread {
Queue<String> queue = new LinkedList<String>();
private static int m = 1;
public Thread1(Queue<String> queue) {
this.queue = queue;
}
@Override
public synchronized void run() {
while (true) {
Random rnd = new Random();
int len = rnd.nextInt(10);// 每次隨機生產(chǎn)10個(gè)一下個(gè)元素加入隊列
for (int i = 0; i < len; i++) {
queue.offer("element:" + (m++));
}
System.out.println("當前運行的線(xiàn)程是：" + Thread.currentThread().getName() + "\t 本次新加入元素數：" + len + "\t 隊列中元素總數是："
+ queue.size());
try {
Thread.sleep(rnd.nextInt(5000));// 隨機休眠5秒之內的時(shí)間
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}

Thread2.java

[java] view plain copy

print?

package cn.zhangshibo.liaocheng.test;
import java.util.LinkedList;
import java.util.Queue;
public class Thread2 extends Thread {
private Queue<String> queue = new LinkedList<String>();
private static int j = 1;
public Thread2(Queue<String> queue) {
this.queue = queue;
}
public synchronized void run() {
while (true) {
String str;
while (!queue.isEmpty()) {
int k = 10;// 每次提交數設置為10，可以根據需要修改
while ((str = queue.poll()) != null) {
--k;
System.out.println(k + "\t" + str);
if (k == 0) {
break;
}
}
System.out.println("當前運行的線(xiàn)程是：" + Thread.currentThread().getName() + "\t 第" + j + "次提交！隊列還剩元素數："
+ queue.size());
j++;
try {
Thread.sleep(5000);// 每次提交以后休眠5秒
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}

Test.java

[java] view plain copy

print?

package cn.zhangshibo.liaocheng.test;
import java.util.LinkedList;
import java.util.Queue;
public class Test {
public static void main(String[] args) {
Queue<String> queue = new LinkedList<String>();
// 創(chuàng )建兩個(gè)線(xiàn)程，讓其不間斷運行
Thread1 t1 = new Thread1(queue);// 線(xiàn)程1模擬隨機添加元素
Thread2 t2 = new Thread2(queue);// 線(xiàn)程2模擬每隔5秒每次提交10個(gè)元素
t1.setName("線(xiàn)程一");
t2.setName("線(xiàn)程二");
t1.start();
t2.start();
}
}

運行結果：

當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：8 隊列中元素總數是：7
9 element:1
8 element:2
7 element:3
6 element:4
5 element:5
4 element:6
3 element:7
2 element:8
當前運行的線(xiàn)程是：線(xiàn)程二第1次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：4 隊列中元素總數是：4
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：4 隊列中元素總數是：8
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：0 隊列中元素總數是：8
9 element:9
8 element:10
7 element:11
6 element:12
5 element:13
4 element:14
3 element:15
2 element:16
當前運行的線(xiàn)程是：線(xiàn)程二第2次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：6 隊列中元素總數是：6
9 element:17
8 element:18
7 element:19
6 element:20
5 element:21
4 element:22
當前運行的線(xiàn)程是：線(xiàn)程二第3次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：2 隊列中元素總數是：2
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：3 隊列中元素總數是：5
9 element:23
8 element:24
7 element:25
6 element:26
5 element:27
當前運行的線(xiàn)程是：線(xiàn)程二第4次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：5 隊列中元素總數是：5
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：5 隊列中元素總數是：10
9 element:28
8 element:29
7 element:30
6 element:31
5 element:32
4 element:33
3 element:34
2 element:35
1 element:36
0 element:37
當前運行的線(xiàn)程是：線(xiàn)程二第5次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：5 隊列中元素總數是：5
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：8 隊列中元素總數是：13
9 element:38
8 element:39
7 element:40
6 element:41
5 element:42
4 element:43
3 element:44
2 element:45
1 element:46
0 element:47
當前運行的線(xiàn)程是：線(xiàn)程二第6次提交！隊列還剩元素數：3
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：5 隊列中元素總數是：8
9 element:48
8 element:49
7 element:50
6 element:51
5 element:52
4 element:53
3 element:54
2 element:55
當前運行的線(xiàn)程是：線(xiàn)程二第7次提交！隊列還剩元素數：0
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：3 隊列中元素總數是：3
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：8 隊列中元素總數是：11
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：1 隊列中元素總數是：12
9 element:56
8 element:57
7 element:58
6 element:59
5 element:60
4 element:61
3 element:62
2 element:63
1 element:64
0 element:65
當前運行的線(xiàn)程是：線(xiàn)程二第8次提交！隊列還剩元素數：2
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：0 隊列中元素總數是：2
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：4 隊列中元素總數是：6
當前運行的線(xiàn)程是：線(xiàn)程一本次新加入元素數：5 隊列中元素總數是：11

本站僅提供存儲服務(wù)，所有內容均由用戶(hù)發(fā)布，如發(fā)現有害或侵權內容，請點(diǎn)擊舉報。

欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久