-
Notifications
You must be signed in to change notification settings - Fork 825
/
Copy pathArrayBlockingQueuePut.java
28 lines (22 loc) · 2.41 KB
/
ArrayBlockingQueuePut.java
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
package basics;
import java.util.concurrent.ArrayBlockingQueue;
public class ArrayBlockingQueuePut {
public static void main(String[] args) {
// define capacity of ArrayBlockingQueue
int capacity = 3;
try {
// Create object of ArrayBlockingQueue
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(capacity);
// Add elements to ArrayBlockingQueue
queue.put(
"Lorem Ipsum,也称乱数å?‡æ–‡æˆ–者哑元文本, 是å?°åˆ·å?ŠæŽ’ç‰ˆé¢†åŸŸæ‰€å¸¸ç”¨çš„è™šæ‹Ÿæ–‡å—。由于曾ç»?一å?°åŒ¿å??的打å?°æœºåˆ»æ„?打乱了一盒å?°åˆ·å—ä½“ä»Žè€Œé€ å‡ºä¸€æœ¬å—ä½“æ ·å“?书,Lorem Ipsum从西元15世纪起就被作为æ¤é¢†åŸŸçš„æ ‡å‡†æ–‡æœ¬ä½¿ç”¨ã€‚它ä¸?ä»…å»¶ç»äº†äº”个世纪,还通过了电å?排版的挑战,其é›?å½¢å?´ä¾?ç„¶ä¿?å˜è‡³ä»Šã€‚在1960年代,â€?Leatrasetâ€?å…¬å?¸å?‘布了å?°åˆ·ç?€Lorem Ipsum段è?½çš„çº¸å¼ ï¼Œä»Žè€Œå¹¿æ³›æ™®å?Šäº†å®ƒçš„使用。最近,计算机桌é?¢å‡ºç‰ˆè½¯ä»¶â€?Aldus PageMakerâ€?也通过å?Œæ ·çš„æ–¹å¼?使Lorem Ipsumè?½å…¥å¤§ä¼—的视野。\n\n");
queue.put(
"Lorem Ipsum,也称乱数å?‡æ–‡æˆ–者哑元文本, 是å?°åˆ·å?ŠæŽ’ç‰ˆé¢†åŸŸæ‰€å¸¸ç”¨çš„è™šæ‹Ÿæ–‡å—。由于曾ç»?一å?°åŒ¿å??的打å?°æœºåˆ»æ„?打乱了一盒å?°åˆ·å—ä½“ä»Žè€Œé€ å‡ºä¸€æœ¬å—ä½“æ ·å“?书,Lorem Ipsum从西元15世纪起就被作为æ¤é¢†åŸŸçš„æ ‡å‡†æ–‡æœ¬ä½¿ç”¨ã€‚它ä¸?ä»…å»¶ç»äº†äº”个世纪,还通过了电å?排版的挑战,其é›?å½¢å?´ä¾?ç„¶ä¿?å˜è‡³ä»Šã€‚在1960年代,â€?Leatrasetâ€?å…¬å?¸å?‘布了å?°åˆ·ç?€Lorem Ipsum段è?½çš„çº¸å¼ ï¼Œä»Žè€Œå¹¿æ³›æ™®å?Šäº†å®ƒçš„使用。最近,计算机桌é?¢å‡ºç‰ˆè½¯ä»¶â€?Aldus PageMakerâ€?也通过å?Œæ ·çš„æ–¹å¼?使Lorem Ipsumè?½å…¥å¤§ä¼—的视野。\n\n");
queue.put(
"Lorem Ipsum,也称乱数å?‡æ–‡æˆ–者哑元文本, 是å?°åˆ·å?ŠæŽ’ç‰ˆé¢†åŸŸæ‰€å¸¸ç”¨çš„è™šæ‹Ÿæ–‡å—。由于曾ç»?一å?°åŒ¿å??的打å?°æœºåˆ»æ„?打乱了一盒å?°åˆ·å—ä½“ä»Žè€Œé€ å‡ºä¸€æœ¬å—ä½“æ ·å“?书,Lorem Ipsum从西元15世纪起就被作为æ¤é¢†åŸŸçš„æ ‡å‡†æ–‡æœ¬ä½¿ç”¨ã€‚它ä¸?ä»…å»¶ç»äº†äº”个世纪,还通过了电å?排版的挑战,其é›?å½¢å?´ä¾?ç„¶ä¿?å˜è‡³ä»Šã€‚在1960年代,â€?Leatrasetâ€?å…¬å?¸å?‘布了å?°åˆ·ç?€Lorem Ipsum段è?½çš„çº¸å¼ ï¼Œä»Žè€Œå¹¿æ³›æ™®å?Šäº†å®ƒçš„使用。最近,计算机桌é?¢å‡ºç‰ˆè½¯ä»¶â€?Aldus PageMakerâ€?也通过å?Œæ ·çš„æ–¹å¼?使Lorem Ipsumè?½å…¥å¤§ä¼—的视野。");
System.out.println("Queue contains: " + queue);
} catch (Exception e) {
System.out.println("Exception: " + e);
}
}
}