主页 / coding / 问题

全部问题(coding)

Martin Hope
xaxazak
Asked: 2025-04-10 01:04:23 +0800 CST
  • 7

我正在构建特征类型（类似于 std::type_identity）来表示不同风格的模板模板。混合类型可变参数值模板是一种特殊情况，我只能想到通过嵌套结构体来实现，如下所示。

clang 接受这一点，但 gcc 不接受。

template <typename ... Ts>
struct variadic_value_metatemplate_builder
    {
        template <template <Ts ... tt_Vs> typename TT>
        struct build
            {
                template <Ts ... Vs>
                using type = TT<Vs ...>;
            };
    };

（编译器资源管理器链接）

gcc 的错误是：

<source>:8:39: error: expansion pattern 'tt_Vs' contains no parameter packs [-Wtemplate-body]
    8 |                 using type = TT<Vs ...>;

谁是对的？

gcc 的错误表述似乎Vs ...不正确，但我猜测这与和Ts ... 的大小要求相同有关，导致它们Vs ...不能自由可变。但据我所知，它们仍然都是参数包。

编辑：旁白：这为什么有用？

实际上，创建一个实际的用例（针对这种特定风格的模板模板）非常困难，但这是我的快速尝试（非常难以置信，不是很好）。

您正在为一组模板化图形操作编写测试例程。有些是 的形式 <int DIMENSION>，有些是 的形式<int DIMENSION, bool UNDO>，等等……您需要为所有 的形式编写一个通用的测试例程，该例程接受一个 形式参数、一组匹配的图形操作以及一组针对这些参数的 constexpr 测试值。然后，您可以执行以下操作：

generic_graphics_test<metabuilder_DIMENSION_UNDO, variadic_auto_constants<2, false>, variadic_auto_constants<3, true>, [etc...]>::test<gfx_translate, gfx_scale, [etc...]>()；

以某种方式gfx_translate测试和的2D 和 3D 可撤消种类gfx_scale。（其中test()将（上述）的实例build作为模板参数，这里表示（原始的、未解析的）翻译和缩放模板操作（作为函子或类似的东西））。

（...这就像元嵌套级别 4 或类似的东西:)

((我希望其中至少有 17% 是半可理解的 :))

不幸的是，目前还没有一个通用的“可能是可变类型或值的模板参数”关键字（虽然很好，但可能很难编写编译器代码），它允许每种可能的模板风格都由一个特征模板来表示。

c++
Martin Hope
Orion
Asked: 2025-04-10 01:03:36 +0800 CST
  • 6

我希望有人能帮忙。

我接手了一个使用 Atlas Mongo DB 的项目。项目要求我从一个集合中获取数据。假设集合中的文档结构如下：

{ _id: 'Parent1', kids: [ { _id: 'Test1', grandkids: [ { name: 'Blah' } ] } ] },
{ _id: 'Parent2', kids: [ { _id: 'Test1', grandkids: [ { name: 'Bloh' } ] } ] },
{ _id: 'Parent3', kids: [ { _id: 'Test2', grandkids: [ { name: 'Bloh' } ] } ] }

当孩子的 _id 为“Test 1”时，我需要获取名字为“Bloh”的孙子，这应该返回来自第二个文档的数据。

使用 Cloud MongoDb Web UI，我尝试进行如下查询，只是想看看是否可以找回第二个文档：

{
    '$and': [
        { 'kids._id': ObjectId('Test 1') },
        { 'kids.grandkids.name': 'Bloh' }
    ]
}

但我没有得到任何结果。我怀疑可能是因为 kids 中的 _id 不唯一。

假设我可以拿回第二份文件，我该如何拿回匹配的孙子呢？

提前致谢！

编辑：

使用 MongoDb 游乐场，这可能是一个问题：

无效查询：

第 3 行：无效的 ObjectId：哈希值必须为 24 个字符长

不幸的是，kid._id 不仅重复，而且长度也不总是 24 个字符。

mongodb
Martin Hope
Wojciech
Asked: 2025-04-10 01:01:23 +0800 CST
  • 5

源代码ConcurrentDictionary提到了使用的可能性TAlternateKey，这是一个 ref 结构。https ://github.com/dotnet/runtime/blob/main/src/libraries/System.Collections.Concurrent/src/System/Collections/Concurrent/ConcurrentDictionary.cs

另外，经过一番搜索，我还发现了其他有趣的例子。例如： https ://github.com/dotnet/runtime/blob/main/src/libraries/Microsoft.Extensions.Caching.Memory/src/MemoryCache.cs

#if NET9_0_OR_GREATER
            private readonly ConcurrentDictionary<string, CacheEntry>.AlternateLookup<ReadOnlySpan<char>> _stringAltLookup;

            public CoherentState()
            {
                _stringAltLookup = _stringEntries.GetAlternateLookup<ReadOnlySpan<char>>();
            }
#endif
//...
#if NET9_0_OR_GREATER
            internal bool TryGetValue(ReadOnlySpan<char> key, [NotNullWhen(true)] out CacheEntry? entry)
                => _stringAltLookup.TryGetValue(key, out entry);
#endif

#if NET9_0_OR_GREATER
            private readonly ConcurrentDictionary<string, CacheEntry>.AlternateLookup<ReadOnlySpan<char>> _stringAltLookup;

            public CoherentState()
            {
                _stringAltLookup = _stringEntries.GetAlternateLookup<ReadOnlySpan<char>>();
            }
#endif

为了获得更好的性能，我是否应该使用ReadOnlySpan<char>作为 Key，而ConcurrentDictionary不是string？

c#
Martin Hope
Nils Werner
Asked: 2025-04-10 01:00:03 +0800 CST
  • 5

我编写了一个 IIR 滤波器类，它具有内部滤波器状态和元素级函数float filter(float x)。当然，由于内部滤波器状态，filter()只能按照序列中排列的顺序对样本调用。

如果我现在将该函数应用于特征数组，例如

input.unaryExpr(filter);

的执行顺序是否unaryExpr()总是严格按照数组中值的顺序，还是可能会出现乱序执行甚至并行化的情况？

明确地编写循环以确保顺序始终符合预期，这样会更安全吗？

现在它似乎运行正常，但我找不到有关其行为的任何明确文档。

c++
Martin Hope
VinceGreg
Asked: 2025-04-10 00:58:51 +0800 CST
  • 6

我的一个函数抛出了多个警告，我想用 来测试一下testthat::expect_warning()。我可以检查一下设计，但文档似乎说这是可能的，使用已弃用的参数all：

all：已弃用如果您需要测试多个警告/消息，您现在需要多次调用 expect_message()/ expect_warning()

（感谢这个答案后的评论）

在下面的 reprex 中（受文档示例启发），devtools::check()正在通过。 devtools::test()也正在通过，但它也会引发警告（当测试特定警告时，会引发另一个警告）。

由于所有警告都是预期的，那么测试多个警告的正确方法是什么？

f1.R

f1 <- function(x) {
  if (x < 0) {
    warning("*x* is already negative")
    warning("this is a second warning")
    return(x)
  }
  -x
}

测试-f1.R

test_that("testing", {
 # Testing the function
  expect_equal(f1(2), -2)
 # Testing a generic warning
  expect_warning(f1(-1))
  # Testing the first warning
  expect_warning(f1(-1), "already negative")
  # Testing the second warning
  expect_warning(f1(-1), "second")
  # Testing no warning
  expect_warning(f1(1), NA)
})

相关输出test()

对应于expect_warning(f1(-1))

警告（test-f1.R:5:3）：测试这是第二个警告

对应于expect_warning(f1(-1), "already negative")

警告（test-f1.R:6:3）：测试这是第二个警告

对应于expect_warning(f1(-1), "second")

警告（test-f1.R:7:3）：测试x已经为负数

Martin Hope
Gord
Asked: 2025-04-10 00:45:16 +0800 CST
  • 5

我正在尝试使用一个使用 STOMP 连接的 Python 客户端来处理来自嵌入式 ActiveMQ Artemis 服务器的一条大消息。客户端创建一个临时队列，然后向“请求”地址发送一条消息。服务器应该生成一个回复，并将其发送回临时队列。在本例中，回复大约是 2.8M 的 JSON 数据。

当服务器尝试回复时，我收到此消息：

info: 11:49:10 372 [Thread-1 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.audit.message   AMQ601500: User anonymous@invm:0 sent a message NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]], context: RoutingContextImpl(Address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6, routingType=null, PreviousAddress=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6 previousRoute:null, reusable=true, version=-2147483639)
..................................................
***** durable queues /temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6:
***** non durable for /temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6:
- queueID=1139 address:/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6 name:2ca84365-155a-11f0-b485-56de892bcc7e filter:null
..................................................
, transaction: null
info: 11:49:10 372 [Thread-3 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.audit.message   AMQ601501: User [email protected]:64850 is consuming a message from 2ca84365-155a-11f0-b485-56de892bcc7e: Reference[1145]:NON-RELIABLE:NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]]
warning: 11:49:10 384 [Thread-3 (ActiveMQ-server-ActiveMQServerImpl::name=localhost)] org.apache.activemq.artemis.core.protocol.stomp   AMQ332071: Unable to send message to client: NullStorageLargeServerMessage[messageID=1145, durable=false, address=/temp-queue/a7f07847-0382-417b-a131-7f626f99a3c6,properties=TypedProperties[_AMQ_LARGE_SIZE=5681703]] 
java.lang.IndexOutOfBoundsException null
    at io.netty.buffer.EmptyByteBuf.checkIndex(EmptyByteBuf.java:1042)
    at io.netty.buffer.EmptyByteBuf.writerIndex(EmptyByteBuf.java:150)
    at io.netty.buffer.WrappedByteBuf.writerIndex(WrappedByteBuf.java:132)
    at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.writerIndex(ChannelBufferWrapper.java:635)
    at org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler.populateFrameBodyFromLargeMessage(VersionedStompFrameHandler.java:394)
    at org.apache.activemq.artemis.core.protocol.stomp.VersionedStompFrameHandler.createMessageFrame(VersionedStompFrameHandler.java:341)
    at org.apache.activemq.artemis.core.protocol.stomp.v12.StompFrameHandlerV12.createMessageFrame(StompFrameHandlerV12.java:57)
    at org.apache.activemq.artemis.core.protocol.stomp.StompConnection.createStompMessage(StompConnection.java:649)
    at org.apache.activemq.artemis.core.protocol.stomp.StompSession.sendMessage(StompSession.java:170)
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1205)
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:522)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:3812)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:3058)
    at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:4157)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:59)
    at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:32)
    at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
    at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:120)

我的理解（可能不正确）是 ActiveMQ Artemis 应该将其分解成更小的块，但它只是给我一个异常。

我肯定漏掉了什么（可能是配置）。有人能告诉我是什么吗？

我正在使用 Artemis 2.40.0。我将对象序列化为 JSON，然后以文本消息的形式发送：

下面是一个表现出这种行为的小程序：

public class Example {
    public static void main(String[] args) throws Exception {
        EmbeddedActiveMQ broker = new EmbeddedActiveMQ();
        broker.setConfigResourcePath("file:example.xml");
        broker.start();

        ServerLocator locator = ActiveMQClient.createServerLocator("vm://0");
        ClientSessionFactory clientSessionFactory = locator.createSessionFactory();
        ClientSession session = clientSessionFactory.createSession();
        session.start();

        ClientConsumer consumer = session.createConsumer("json.requests");
        consumer.setMessageHandler(new MessageHandler() {
            @Override
            public void onMessage(ClientMessage message) {
                byte[] bytes = new byte[message.getBodySize()];
                message.getBodyBuffer().readBytes(bytes);
                JsonElement jsonElement = JsonParser.parseString(new String(bytes));
                String replyTo = jsonElement.getAsJsonObject().get("reply-to").getAsString();
                String s = generateLargeMessage();
                try {
                    ClientProducer producer = session.createProducer("/temp-queue/" + replyTo);
                    ClientMessage m = session.createMessage(TEXT_TYPE, false);
                    m.getBodyBuffer().writeNullableSimpleString(SimpleString.of(s));
                    producer.send(m);
                    session.commit();
                } catch (ActiveMQException e) {
                    System.err.println("Couldn't send message: " + e.getMessage());
                }
            }
        });
    }

    private static String generateLargeMessage() {
        StringBuilder sb = new StringBuilder();
        while (sb.length() < 2000000) {
            sb.append("abcdefghijklmnopqrstuvwxyz\n");
        }
        return sb.toString();
    }
}

这是我的 xml：

<configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:activemq" xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
    <core xmlns="urn:activemq:core">
        <persistence-enabled>false</persistence-enabled>
        <security-enabled>false</security-enabled>
        <acceptors>
            <acceptor name="in-vm">vm://0</acceptor>
            <acceptor name="in-tcp">tcp://localhost:61616</acceptor>
        </acceptors>

        <addresses>
            <address name="json.requests">
                <anycast>
                    <queue name="json.requests"/>
                </anycast>
            </address>
        </addresses>
    </core>
</configuration>

这是我的测试python：

#!venv/bin/python3

import time
import stomp
import json
import uuid

myuuid = uuid.uuid4()
print(f"myuuid = {myuuid}")

conn = stomp.Connection12([('127.0.0.1', 61616)], heartbeats=(5000,5000))
conn.set_listener('', stomp.PrintingListener())

conn.connect(None, None, wait=True)

print("subscribing...")
conn.subscribe(destination=f"/temp-queue/{myuuid}", id=1, ack='auto')

msg = json.dumps({'type':'DaoRequest', 'request': 'users', 'reply-to': f"{myuuid}" })
print(f'sending {msg} to json.requests')

resp = conn.send(body=msg, destination="json.requests")
time.sleep(60)
activemq-artemis
Martin Hope
Paul Grinberg
Asked: 2025-04-10 00:29:10 +0800 CST
  • 6

我的数据采用以下简化格式

[
  {
    "a": "foo",
    "b": [
      {
        "x": 1,
        "y": true
      }
    ]
  },
  {
    "a": "foo",
    "b": [
      {
        "x": 1,
        "y": true
      },
      {
        "x": 99,
        "y": false
      }
    ]
  },
  {
    "a": "bar",
    "b": []
  }
]

我正在尝试获取每个 unique的所有条目数。我尝试先按 a 分组，这样至少可以得到“unique ”部分。但是，我不知道如何获取group_by 结果中所有条目数。单纯按like分组是行不通的。bajq '. | group_by(.a)[]abbjq '. | group_by(.a)[] | group_by(.b)[]'

或者，我尝试过jq -n 'jq '[ .[] | {a, n:(.b|length)} ] | group_by(.a)'但仍然不知道如何跨条目计数。

有什么建议吗？本例的最终答案是 3 个b条目foo，0 个b条目bar

json
Martin Hope
Sergiu Starciuc
Asked: 2025-04-10 00:15:02 +0800 CST
  • 8

使用 Haskellcrypton包，我尝试生成相同的输出，openssl dgst但不知道哪里出错了。请帮忙。

openssl dgst：

$ echo "TheMessage" | openssl dgst -sha256 -mac HMAC -macopt key:"TheKey"
SHA2-256(stdin)= 7b2e5669f4a5fa30a3fa0e9147f8975883cddff77725c99a6db07395b9665974

加密：

ghci> hmacGetDigest ( hmac ("TheKey" :: ByteString) ("TheMessage" :: ByteString) :: HMAC SHA256 )
39c17c48adbc2ea4d469af9ecb2569f921053843af2a0a7716b7a180b0cedff6

谢谢。

haskell
Martin Hope
einpoklum
Asked: 2025-04-10 00:12:08 +0800 CST
  • 5

考虑以下程序：

#include <array>

int main() {
    throw std::logic_error("hi");
}

在某些 C++ 编译器（或者更确切地说，标准库）中，这可以编译。例如，libstdc++ 8，其中<array>包含<stdexcept>。但在其他标准库实现中，例如 libstdc++ 11，则无法编译。

我能让 clang-tidy 警告我这种情况吗？至少相对于标准库来说？

如果没有 - 是否有其他工具（可能不是基于 clang）可以帮助我检测这个问题？

c++
Martin Hope
Nikos
Asked: 2025-04-10 00:04:11 +0800 CST
  • 7

我正在使用atakrig包。当我将核心数设置为 8 进行并行计算时，出现以下错误：0%Error in serialize(data, node$con) : error writing to connection。如果我将核心数设置为 4，并行处理就正常了（没有错误）。我在使用该包的函数时出现此错误ataStartCluster()。

cl <- parallel::makeCluster(8, type = "PSOCK")我发现，如果设置而不是，就可以解决这个问题ataStartCluster()。我还比较了使用 和不使用 时的执行时间parallel::makeCluster()，看看并行计算是否按预期工作，结果确实如此。

使用并行代码时，cl <- parallel::makeCluster(8, type = "PSOCK")执行时间为 1.5 分钟，而不使用并行代码时，执行时间为 3.2 分钟。问题是，我的另一台笔记本电脑上没有这个问题，它有 4GB 内存和 Windows 10 系统，但 R 版本和软件包与这台笔记本电脑上的相同（请参阅下面的会话信息）。

我正在使用的代码：

library(atakrig)
library(terra)
rpath <- system.file("extdata", package="atakrig")
aod3k <- rast(file.path(rpath, "MOD04_3K_A2017042.tif"))
aod10 <- rast(file.path(rpath, "MOD04_L2_A2017042.tif"))
aod3k.d <- discretizeRaster(aod3k, 1500)
aod10.d <- discretizeRaster(aod10, 1500)
grid.pred <- discretizeRaster(aod3k, 1500, type = "all")
aod3k.d$areaValues$value <- log(aod3k.d$areaValues$value)
aod10.d$areaValues$value <- log(aod10.d$areaValues$value)
## area-to-area Kriging ---# point-scale variogram from combined AOD-3k and AOD-10
aod.combine <- rbindDiscreteArea(x = aod3k.d, y = aod10.d)
vgm.ok_combine <- deconvPointVgm(aod.combine, model="Exp", ngroup=12, rd=0.75)
# point-scale cross-variogram
aod.list <- list(aod3k=aod3k.d, aod10=aod10.d)
aod.list <- list(aod3k=aod3k.d, aod10=aod10.d)
vgm.ck <- deconvPointVgmForCoKriging(aod.list, model="Exp", ngroup=12, rd=0.75,fixed.range = 9e4)
# prediction
cl <- parallel::makeCluster(8, type = "PSOCK")
pred.ataok <- ataKriging(aod10.d, grid.pred, vgm.ck$aod10, showProgress = TRUE, nopar = FALSE)
parallel::stopCluster(cl)

会话信息：

R version 4.4.3 (2025-02-28 ucrt)
Platform: x86_64-w64-mingw32/x64
Running under: Windows 11 x64 (build 26100)

Matrix products: default


locale:
[1] LC_COLLATE=English_United States.utf8  LC_CTYPE=English_United States.utf8    LC_MONETARY=English_United States.utf8
[4] LC_NUMERIC=C                           LC_TIME=English_United States.utf8    


attached base packages:
[1] stats     graphics  grDevices utils     datasets  methods   base     

other attached packages:
[1] terra_1.8-42    atakrig_0.9.8.1

loaded via a namespace (and not attached):
 [1] DBI_1.2.3          KernSmooth_2.23-26 sf_1.0-20          doSNOW_1.0.20      zoo_1.8-13         spacetime_1.3-3    xts_0.14.1        
 [8] e1071_1.7-16       snow_0.4-4         sp_2.2-0           gstat_2.1-3        grid_4.4.3         classInt_0.4-11    foreach_1.5.2     
[15] FNN_1.1.4.1        intervals_0.15.5   compiler_4.4.3     codetools_0.2-20   Rcpp_1.0.14        rstudioapi_0.17.1  lattice_0.22-7    
[22] class_7.3-23       parallel_4.4.3     magrittr_2.0.3     tools_4.4.3        proxy_0.4-27       iterators_1.0.14   units_0.8-7

编辑

通过调用包foreach（例如library(foreach)），我成功运行了代码。我不知道这有什么用，也不知道它有什么作用。

上一页
下一页