小编Man*_*odi的帖子

我需要在Matlab中实现以下算法.

1. 假设 A = [3 4 1 9 5]
2. A随机置换,A = [5 1 4 3 9]
3. 在前两个元素中添加2: A = [7 3 4 3 9]
4. 置换回来, A = [3 4 3 9 7]

我正在使用randperm()功能来置换:

index = randperm(numel(A));
A = A(index);

但问题是如何在将数组更改A为第一个排列之后将其置换回来.

我有一个 Redis 管道说：

r = redis.Redis(...).pipline()

假设我需要删除任何残留查询（如果存在于管道中而不执行）。有类似的东西r.clear()吗？

我有搜索文档和源代码，但找不到任何东西。

我刚刚看到了 Java Beans 规范。我觉得只使用 getter、setter 和空构造函数会使代码更加忙碌，而且开发人员需要管理轨道以正确设置所有必需的实例。

有人可以指出我使用这种设计的好用例吗？我无法感受它。我能想到一种用途 - “当您需要创建一个类的实例时，它的数据成员将在稍后的代码中决定。”

编辑：伙计们，我不是在发起讨论。不想讨论优点/缺点。我不是在寻找像 spring 等当前必须使用 Beans 的库。我正在寻找一个示例来了解 Java bean 将带来的工程优势。“Java Beans 设计将有所帮助的一个例子”

我的代码中遇到了死锁情况.我使用以下测试代码重现了该场景(也请查看行号注释).

我有一个ExecuterService需要3个任务,2个任务在同一个对象上有一个同步块,没有初始化它应该有null值.

synchronized(null){}是不允许在java中,所以我期待一个错误line-2.但是,这是以死锁执行的.即前三个任务在第三个任务中等待.(见输出-1)

现在,如果我更改line-1为Object lock = new Object();代码将完美地工作,没有任何死锁(输出-2).我只是想知道当我们提供未初始化的互斥对象时JVM到底发生了什么？看起来JVM正在为它创建一个静态副本,它由所有任务共享.因此陷入僵局

public class Test {
    Object lock; //line -1
    Integer a = 10;

    public static void main(String[] arg) {
        new Test().doIt();
    }

    public void doIt() {
        ExecutorService service = Executors.newFixedThreadPool(3);

        service.submit(new Runnable() {
            public void run() {
                synchronized (Test.this.lock) { //line -2
                    try {
                        Thread.sleep(1000 * 5);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    Test.this.a = (int) …

我过去曾与Kafka合作过,最近需要在AWS Kinesis Stream上移植部分数据管道.现在我已经读到Kinesis实际上是Kafka的一个分支并且有许多相似之处.

但是我没有看到我们如何让多个消费者从同一个流中读取,每个消费者都有相应的偏移量.每个数据记录都有一个序列号,但我找不到任何特定于消费者的信息(Kafka group Id？).

是否真的可以让不同的消费者拥有与同一AWS Kinesis Stream不同的摄取率？

假设我们在Java中有两个BitSet对象,其值为

//<MSB....LSB>
B1:<11000101>
B2:<10111101>

我们如何比较B1和B2才能知道B1代表的值大于B2代表的值.

是否为BitSet重载了逻辑运算符(>,<,==)？或者我是否必须编写自己的实现？

更新:刚发现"运算符>未定义参数类型java.util.BitSet,java.util.BitSet".有没有内置方法可以这样做？