- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试实现一个小程序,该程序将使用 SynchronousQueue 按升序对整数数组/vector 进行排序。
我接手的方法是创建一个线程池,其中每个线程将通过迭代元素并比较位置 i< 上的元素按升序对元素进行一次排序/em> 和 i+1 并交换它们。
所以我创建了一个执行此交换的类,并将 iteration 数字、两个 SynchronousQueues 和数组本身作为参数,如下所示:
class OrderAsc extends Thread {
int length;
int iteration;
SynchronousQueue<ArrayList> st, dr;
ArrayList<Integer> vector;
boolean swapMade;
OrderAsc( int iteration, SynchronousQueue<ArrayList> st, SynchronousQueue<ArrayList> dr, ArrayList<Integer> vector) throws InterruptedException{
this.length = vector.size();
this.st = st;
this.dr = dr;
this.vector = vector;
this.iteration = iteration;
this.swapMade = false;
}
// Rularea thread-ului
@Override
public void run(){
if(iteration > 0){
try {
vector = st.take();
System.out.println(iteration + " get " + vector);
} catch (InterruptedException ex) {
System.out.println(ex);
}
}
// System.out.println(iteration + " >>> " + vector);
for(int i = 0; i < length-1; i++){
if(vector.get(i) > vector.get(i+1)){
int tmp = vector.get(i);
vector.set(i, vector.get(i+1));
vector.set(i+1, tmp);
swapMade = true;
}
}
if(swapMade){
try {
dr.put(vector);
System.out.println(iteration + " put " + vector);
} catch (InterruptedException ex) {
System.out.println(ex);
}
} else {
// Display result
System.out.println(vector);
}
System.exit(0);
}
}
在主类中,我创建了一个包含此类对象的 ArrayList,如下所示:
ArrayList<OrderAsc> orderFilter = new ArrayList<OrderAsc>(n+2);
for(int i = 0; i < n + 2; i++){
orderFilter.add(i, new OrderAsc(i, st, dr, vector));
st = dr;
dr = new SynchronousQueue<ArrayList>();
}
for(int i=0; i < n + 2; i++){
orderFilter.get(i).setDaemon(true);
orderFilter.get(i).start();
}
考虑到 OrderAsc 对象的实现,第一个线程将对数据进行排序迭代,然后将结果放入 dr 队列。然后,被阻塞的下一个线程将等待第一个线程TAKE这个结果,再次过滤,然后将它发送给下一个,直到整个数组被排序。
出乎意料的是,似乎线程并没有一直等待那些 SynchronousQueues,并且出于某些原因,它们有时会随机获取数据,如下所示:
1 get [5, 4, 3, 2, 1, 6]
0 put [4, 3, 2, 1, 5, 6]
1 put [4, 3, 2, 1, 5, 6]
2 get [4, 3, 2, 1, 5, 6]
BUILD SUCCESSFUL (total time: 5 seconds)
SynchronousQueue 是否有不同的工作方式而我实现错误?
最佳答案
我试过用一个同步队列重写你的程序...简而言之,线程 0 放入初始的未排序 vector ,并且其余线程开始以迭代方式进行排序。
import java.util.ArrayList;
import java.util.concurrent.SynchronousQueue;
class OrderAsc extends Thread {
int length;
int iteration;
SynchronousQueue<ArrayList> st, dr;
ArrayList<Integer> vector;
boolean swapMade;
OrderAsc( int iteration, SynchronousQueue<ArrayList> st, SynchronousQueue<ArrayList> dr, ArrayList<Integer> vector) throws InterruptedException{
this.length = vector.size();
this.st = st;
this.dr = dr;
this.vector = vector;
this.iteration = iteration;
this.swapMade = false;
}
@Override
public void run(){
if ( iteration == 0 ){
try {
System.out.println("\n " + iteration + " put " + vector);
st.put(vector);
Thread.currentThread().interrupt();
return;
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
else{
try {
vector = st.take();
// System.out.println("\n Take in Thread : " + Thread.currentThread().getName());
System.out.println(iteration + " take " + vector);
} catch (InterruptedException ex) {
System.out.println(ex);
}
}
for(int i = 0; i < vector.size() - 1; i++){
if(vector.get(i) > vector.get(i+1)){
int tmp = vector.get(i);
vector.set(i, vector.get(i+1));
vector.set(i+1, tmp);
swapMade = true;
}
}
if(swapMade){
//System.out.println("\n Swap Done in Thread : " + Thread.currentThread().getName());
try {
st.put(vector);
System.out.println(iteration + " sorted " + vector);
} catch (InterruptedException ex) {
System.out.println(ex);
}
}
//System.out.println("\n Exiting Thread : " + Thread.currentThread().getName());
// System.exit(0);
}
public static void main(String args[]){
ArrayList<OrderAsc> orderFilter = new ArrayList<OrderAsc>(5);
ArrayList<Integer> vector = new ArrayList<Integer>(6);
vector.add(4);
vector.add(1);
vector.add(3);
vector.add(5);
vector.add(6);
vector.add(2);
System.out.println("\n Unsorted Array " + vector + "\n\n");
int n = vector.size();
//vector.add(1);
//vector.add(5);
SynchronousQueue<ArrayList> st1 = new SynchronousQueue<ArrayList>();
SynchronousQueue<ArrayList> dr1 = new SynchronousQueue<ArrayList>();
for(int i = 0; i < n ; i++){
try {
orderFilter.add(i, new OrderAsc(i, st1, dr1, vector));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//st1 = dr1;
//dr1 = new SynchronousQueue<ArrayList>();
}
for(int i=0; i < n - 1; i++){
//orderFilter.get(i).setDaemon(true);
orderFilter.get(i).start();
}
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("\n Voila Thanks Threads and the Sorted Array Is ");
for(int i = 0; i < vector.size(); i++){
System.out.print(" " + vector.get(i) + " ");
}
}
}
关于java - 为什么SynchronousQueue允许其他线程随机取?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30286541/
我在字符串中有一个大词。例子白 Wine 额外优惠。 我想在第一行使用“White”,在第二行使用“wine extra offer”。使用下面的代码: string value="White win
我想在无符号中执行一些算术运算,需要取负整数的绝对值,比如 do_some_arithmetic_in_unsigned_mode(int some_signed_value) { unsign
我正在努力使用 data.table 来总结向量函数的结果,这在 ddply 中很容易。 问题 1:使用带有矢量输出的(昂贵的)函数聚合 dt dt[ , as.list(quantile(x)),
我有两个分数列表; 说 A = [ 1/212, 5/212, 3/212, ... ] 和 B = [ 4/143, 7/143, 2/143, ... ] . 如果我们定义 A' = a[0] *
我已经使用 numpy 从 csv 文件中获取数据。 numpy 数组的尺寸为:100*20。我如何取列的平均值(比如 col 3,5,8)并用包含这 3 个 cols 平均值的新列替换它们 如果
在 Rust 中取任意数的 n 次根的最佳方法是什么?例如,num crate 只允许取整数类型的第 n 个主根,即 floor'ed 或 ceil'ed 值......如何最好地接近实际值? 最佳答
看起来这应该很容易,但我很困惑。我已经掌握了使用 dplyr 进行编程的大致技巧0.7,但为此苦苦挣扎:How do Iprogram in dplyr我想要编程的变量是否是一个字符串? 我正在抓取数
在 Rust 中取任意数的 n 次根的最佳方法是什么?例如,num crate 只允许取整数类型的第 n 个主根,即 floor'ed 或 ceil'ed 值......如何最好地接近实际值? 最佳答
我有一个 pandas 数据框,其中有一列名为“coverage”。对于一系列特定索引值,我想获取前 100 行的平均“覆盖率”值。例如,对于索引位置 1001,我想要第 901-1000 行的平均“
import pandas as pd data = {'date': ['1998-03-01', '2001-04-01','1998-06-01','2001-08-01','2001-05-0
我有一个包含 100 个数字的 NSArray。我想创建一个 5 个数字的 NSArray。第二个数组中的第一个数字是第一个数组中前 20 个数字的平均值。第二个数字是第一个数组中第二组 20 个数字
我该怎么做?我试过 abs() 但它只适用于整数。有内置的方法吗? CGFloat flo = -123; abs(flo) 返回 0 最佳答案 使用 fabs() CGFloat f = -123.
我正在采用以下计算的 log2: tl_out.a.bits.size := log2Ceil(s1_row * s2_column * 4.U) 其中,s1_row 和 s2_column 是 UI
如何从 m 个元素集合中取出 n 个元素,以便在元素用完时从头开始? List list = new List() {1, 2, 3, 4, 5, 6, 7, 8, 9, 10}; List newL
我已经完成了研究,但似乎找不到有关该主题的足够文档。 在 Object streams 上尝试一些代码时,我注意到将 BufferedOutputStream 放入 ObjectOutputStrea
我需要计算数据中连续时间组之间的差异,如下所示 from io import StringIO import pandas as pd strio = StringIO("""\
我在 Mongo 数据库中有以下文档: { _id: 1, question: "Blue or red?", __v: 0, votes: [9, 5] } 我想在后
好吧,宇宙中一定有人知道这个问题的答案。 我已经在这里问过这个问题,但仍然没有解决方案。 我需要保留和换行 div 中的文本。到目前为止,我很难想出解决方案。我找到的最佳解决方案并不适用于所有浏览器。
我正在尝试采用 3 个单独的整数输入(年、月、日)并采用这 3 个条目并从中形成一个日期对象,以便我可以使用它来比较其他日期。 这是我目前所拥有的,不知从何而来: public void compar
在我的 IOS 项目中,我有一个包含该函数的自定义 Logger 类(单例) - (void)log:(NSString *)domain logLevel:(int)level logMessage
我是一名优秀的程序员,十分优秀!