FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
array-queue.java/Main.java at master · moocf/array-queue.java · GitHub
Uh oh!
There was an error while loading.
Please reload this page
.
moocf
/
array-queue.java
Public
Notifications
You must be signed in to change notification settings
Fork
0
Star
1
Code
Issues
0
Pull requests
0
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
array-queue.java
/
Main.java
Copy path
More file actions
More file actions
Latest commit
History
History
History
102 lines (95 loc) · 2.69 KB
Breadcrumbs
array-queue.java
/
Main.java
Copy path
File metadata and controls
102 lines (95 loc) · 2.69 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
import
java
.
util
.*;
class
Main
{
static
Deque
<
Integer
>
queue
;
static
ArrayQueue
<
Integer
>
concurrentQueue
;
static
List
<
Integer
>[]
deqValues
;
static
int
TH
=
10
,
NUM
=
1000
;
// Each unsafe thread enqs N numbers and deqs N, adding
// them to its own deqValues for checking; using Java's
// sequential queue implementation, ArrayDeque.
static
Thread
unsafe
(
int
id
,
int
x
,
int
N
) {
return
new
Thread
(() -> {
String
action
=
"enq"
;
try
{
for
(
int
i
=
0
,
y
=
x
;
i
<
N
;
i
++)
queue
.
addLast
(
y
++);
Thread
.
sleep
(
1000
);
action
=
"deq"
;
for
(
int
i
=
0
;
i
<
N
;
i
++)
deqValues
[
id
].
add
(
queue
.
removeFirst
());
}
catch
(
Exception
e
) {
log
(
id
+
": failed "
+
action
); }
});
}
// Each safe thread enqs N numbers and deqs N, adding
// them to its own deqValues for checking; using
// ArrayQueue.
static
Thread
safe
(
int
id
,
int
x
,
int
N
) {
return
new
Thread
(() -> {
String
action
=
"enq"
;
try
{
for
(
int
i
=
0
,
y
=
x
;
i
<
N
;
i
++)
concurrentQueue
.
enq
(
y
++);
Thread
.
sleep
(
1000
);
action
=
"deq"
;
for
(
int
i
=
0
;
i
<
N
;
i
++)
deqValues
[
id
].
add
(
concurrentQueue
.
deq
());
}
catch
(
Exception
e
) {
log
(
id
+
": failed "
+
action
);
e
.
printStackTrace
(); }
});
}
// Checks if each thread dequeued N values, and they are
// globally unique.
static
boolean
wasLIFO
(
int
N
) {
Set
<
Integer
>
set
=
new
HashSet
<>();
boolean
passed
=
true
;
for
(
int
i
=
0
;
i
<
TH
;
i
++) {
int
n
=
deqValues
[
i
].
size
();
if
(
n
!=
N
) {
log
(
i
+
": dequeued "
+
n
+
"/"
+
N
+
" values"
);
passed
=
false
;
}
for
(
Integer
x
:
deqValues
[
i
])
if
(
set
.
contains
(
x
)) {
log
(
i
+
": has duplicate value "
+
x
);
passed
=
false
;
}
set
.
addAll
(
deqValues
[
i
]);
}
return
passed
;
}
@
SuppressWarnings
(
"unchecked"
)
static
void
testThreads
(
boolean
safe
) {
queue
=
new
ArrayDeque
<>();
concurrentQueue
=
new
ArrayQueue
<>(
TH
*
NUM
);
deqValues
=
new
List
[
TH
];
for
(
int
i
=
0
;
i
<
TH
;
i
++)
deqValues
[
i
] =
new
ArrayList
<>();
Thread
[]
threads
=
new
Thread
[
TH
];
for
(
int
i
=
0
;
i
<
TH
;
i
++) {
threads
[
i
] =
safe
?
safe
(
i
,
i
*
NUM
,
NUM
) :
unsafe
(
i
,
i
*
NUM
,
NUM
);
threads
[
i
].
start
();
}
try
{
for
(
int
i
=
0
;
i
<
TH
;
i
++)
threads
[
i
].
join
();
}
catch
(
Exception
e
) {}
}
public
static
void
main
(
String
[]
args
) {
log
(
"Starting "
+
TH
+
" threads with sequential queue"
);
testThreads
(
false
);
log
(
"Was LIFO? "
+
wasLIFO
(
NUM
));
log
(
""
);
log
(
"Starting "
+
TH
+
" threads with array queue"
);
testThreads
(
true
);
log
(
"Was LIFO? "
+
wasLIFO
(
NUM
));
log
(
""
);
}
static
void
log
(
String
x
) {
System
.
out
.
println
(
x
);
}
}
Back
|
FazBrowse Home
|
New Git URL