小编Jak*_*kub的帖子

在Python中锁定循环时线程饥饿

我有一个应用程序,它在一个线程中的循环中获取锁以执行某些任务.还有第二个线程也想不时获取锁.问题是,第二个线程几乎没有机会执行它的工作,因为第一个线程几乎总是先锁定.我希望以下代码能够澄清我想说的内容:

import time
from threading import Lock, Thread

lock = Lock()


def loop():
    while True:
        with lock:
            time.sleep(0.1)

thread = Thread(target=loop)
thread.start()

before = time.time()
lock.acquire()
print('Took {}'.format(time.time() - before))
Run Code Online (Sandbox Code Playgroud)

如果应用程序到达print您将注意到它需要的方式不仅仅是0.1秒.但有时也会发生它只是无限期等待.我已经在Debian Linux 8上的Python 2.7.11和Python 3.4.3中对它进行了测试,它的工作方式相同.

这种行为对我来说是违反直觉的.毕竟当锁定被释放时loop,它lock.acquire已经在等待它的释放,它应该立即获得锁定.但是看起来循环首先获得锁定,即使它在释放时刻根本没有等待它的释放.

我发现的解决方案是在处于解锁状态的每个循环迭代之间休眠,但这并不是一个优雅的解决方案,它也没有向我解释发生了什么.

我错过了什么?

python multithreading

9
推荐指数
1
解决办法
1585
查看次数

如何检查字符串是否代表浮点数?

Rust中是否有一种方法可以检查字符串是否包含浮点数而不使用正则表达式?

给出类似结果的东西(使用正则表达式:https://regex101.com/r/pV6wJ6/2)

re = Regex::new(r#"^-?(0|[1-9]\d*)(\.\d+)?$"#).unwrap()
assert_eq!(is_number(some_string), re.is_match(some_string))
Run Code Online (Sandbox Code Playgroud)

rust

7
推荐指数
1
解决办法
2630
查看次数

如何从 SQS 消息中获取“Ap​​proximateReceiveCount”

我正在使用亚马逊 SQS。我的目标是使用 Java SDK(v2.10.4,Java 11)从API 操作读取ApproximateReceiveCount属性。ReceiveMessage

我尝试了以下代码,但message.attributes()不包含所需的密钥:

String getApproximateReceiveCount() {
    var receiveMessageRequest = ReceiveMessageRequest.builder()
        .queueUrl("https://sqs.eu-west-1.amazonaws.com/012345678910/my-example-queue")
        .build();
    var sqsClient = SqsClient.builder().endpointOverride(URI.create("http://localhost:4576")).build();
    var response = sqsClient.receiveMessage(receiveMessageRequest);
    var message = response.messages().get(0);
    return message.attributes().get(MessageSystemAttributeName.APPROXIMATE_RECEIVE_COUNT);
}
Run Code Online (Sandbox Code Playgroud)

在此地图中如何接收密钥条目MessageSystemAttributeName.APPROXIMATE_RECEIVE_COUNT

java amazon-sqs amazon-web-services

5
推荐指数
1
解决办法
3694
查看次数

如何将实现特定特征的对象数组传递给函数?

为了学习Rust语法,我决定实现一个对传入数组进行排序的函数:

fn sort(array) {
    // actual sorting
}
Run Code Online (Sandbox Code Playgroud)

这个问题中,我发现了如何传递数组并更改其内容,但除此之外,数组必须包含可以比较的类型.我找到了这个std::cmp::PartialOrd特性,并发现数组的元素需要实现它.

通过将这些知识与Rust书中关于动态调度的段落联系起来,我构建了这样的东西:

use std::cmp;

fn sort(arr: &mut [&std::cmp::PartialOrd]) {
    // actual sorting
}
Run Code Online (Sandbox Code Playgroud)

这不编译:

error[E0393]: the type parameter `Rhs` must be explicitly specified
 --> src/lib.rs:3:21
  |
3 | fn sort(arr: &mut [&std::cmp::PartialOrd]) {
  |                     ^^^^^^^^^^^^^^^^^^^^ missing reference to `Rhs`
  |
  = note: because of the default `Self` reference, type parameters must be specified on object types
Run Code Online (Sandbox Code Playgroud)

是否有正确的语法来实现将实现特定特征的对象数组传递给函数?

arrays rust

4
推荐指数
1
解决办法
899
查看次数

Rust 是否会针对计算范围内的循环进行优化?

作为练习,我尝试对 Rust 1.3.0 中的代码进行微优化。我在数组上有一个循环。像这样的东西:

loop {
    for i in 0..arr.len() {
        // something happens here
    }
}
Run Code Online (Sandbox Code Playgroud)

由于 Rust 中的数组大小是固定的,编译器是否会通过arr.len()仅计算一次并重用该值来优化代码,还是会在顶层循环的每次传递中计算表达式?这个问题可以扩展到除了arr.len().

换句话说,上面的代码是否等同于:

let arr_len = arr.len();

loop {
    for i in 0..arr_len {
        // something happens here
    }
}
Run Code Online (Sandbox Code Playgroud)

optimization micro-optimization rust

3
推荐指数
1
解决办法
1088
查看次数

非导出类型的类型声明

我正在使用第3方程序包,该程序包允许您通过导出功能创建某些非导出类型的结构。

package squirrel

type expr struct {
    sql string
    args []interface{}
}

func Expr(sql string, args ...interface{}) expr {
    return expr{sql: sql, args: args}
}
Run Code Online (Sandbox Code Playgroud)

由于该库的其他功能接受数据的方式,我最终得到了这样的映射:

m := map[string]interface{} {
    "col1": 123,
    "col2": "a_string",
    "col3": Expr("now()"),
}
Run Code Online (Sandbox Code Playgroud)

但是由于该库中的函数不同,我需要squirrel.expr从该地图中过滤掉所有内容。

显然,我无法通过以下方式直接声明类型:

filtered := make(map[string]interface{})
for k, v := range m {
    switch v.(type) {
    case squirrel.expr:
        continue
    default:
        filtered[k] = v
    }
}
Run Code Online (Sandbox Code Playgroud)

还有另一种方法可以达到相同的结果吗?

types go

1
推荐指数
1
解决办法
95
查看次数

匿名对象的方法范围-Kotlin

在Kotlin中,如果我在匿名对象上定义方法,有时可以访问它,而其他时候则不能。这似乎与范围规则有关,但我不确定。

在下面的代码示例中,对的访问example3.field.method()将导致编译错误。有趣的是,example2.field.method()编译就很好。

以下行为的解释可能是什么?

class Example3 {
    val field = object {
        fun method() {}
    }
}

fun showcase() {
    val example1 = object {
        fun method() {}
    }
    example1.method()
    println(example1::class.qualifiedName)

    class Example2 {
        val field = object {
            fun method() {}
        }
    }

    val example2 = Example2()
    example2.field.method()
    println(example2::class.qualifiedName)

    val example3 = Example3()
    // example3.field.method()  // won't compile
    println(example3::class.qualifiedName)
}
Run Code Online (Sandbox Code Playgroud)

kotlin

1
推荐指数
1
解决办法
51
查看次数