小编Eug*_*sky的帖子

我正在创建一个节点C++插件,它应该回调一个js函数,因为事件是由一些不受我控制的其他线程触发的(它实际上是我使用的托管dll的.net线程).由于JS世界是单线程的,我不能只保留js函数引用并从非js线程调用它.我甚至无法创建我想传递给该线程上的回调函数的参数.

我已经看到uv_queue_work在你希望从js线程移动工作并且一旦完成并且从js线程回调以执行你需要做的任何事情的情况下使用,例如回调一个js函数.

供以后参考,这是函数的签名:

int uv_queue_work(uv_loop_t* loop, uv_work_t* req, uv_work_cb work_cb,
uv_after_work_cb after_work_cb);

调用uv_queue_work对于一次性工作来说很好,而且我可能会通过链接uv_queue_work来自from的调用来任意调用我after_work_cb,同时work_cb与其他线程同步,但我想知道是否有更简单的方法来执行它.

就像node.js提供的fn一样,可以被任何其他线程直接调用,其中fn指针指向下一次在主js线程上执行的代码.任何的想法？

我想使用我发现的这个库,它是zeromq的纯java端口(不是包装器).我正在尝试测试它,虽然它声称有一些好的数字,我正在执行的测试结果相当差,它甚至在本地执行(客户端和服务在同一台机器上).我确定这是我做错了.需要约.5秒执行此10.000消息循环.

我所做的只是采用Hello world示例并删除了暂停和sysouts.这是代码:

服务器:

package guide;

import org.jeromq.ZMQ;

public class hwserver{
    public static void main(String[] args) throws Exception{

        //  Prepare our context and socket
        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket socket = context.socket(ZMQ.REP);

        System.out.println("Binding hello world server");
        socket.bind ("tcp://*:5555");        

        while (true) {                  
            byte[] reply = socket.recv(0);
            String requestString = "Hello" ;
            byte[] request = requestString.getBytes();              
            socket.send(request, 0);            
        }              
    }
}

客户端:

package guide;

import org.jeromq.ZMQ;

public class hwclient{
    public static void main(String[] args){
        ZMQ.Context context = ZMQ.context(1); …

Java 的AtomicInteger优惠public final boolean compareAndSet(int expect, int update)。如果false返回，我想知道比较失败时的实际值是多少。这在Java中可能吗？

在 .Net 中，有public static int CompareExchange(ref int location1, int value, int comparand), 总是返回原始值。

那可能吗？

正式的.Net客户端融合的kafka-dotnet似乎仅提供消费者和生产者功能。

而且（从我记得很久以前就研究过Kafka流的情况来看），我相信Kafka Streams处理器始终在运行Kafka本身的JVM上运行。在这种情况下，原则上是不可能的。

的文档AsyncContext具有可同步工作的此示例（仅作了少许修改，但仍可正常工作）：

#include "napi.h"

void MakeCallbackWithAsyncContext(const Napi::CallbackInfo& info)
{
  Napi::Function callback = info[0].As<Napi::Function>();
  Napi::Object resource = info.Env().Global().As<Napi::Object>();;    
  Napi::AsyncContext context(info.Env(), "async_context_test", resource);

  callback.MakeCallback(Napi::Object::New(info.Env()),
      std::initializer_list<napi_value>{}, context);
}

我想知道如何异步使用它-这是我的最新照片：

Napi::AsyncContext* _context;
Napi::FunctionReference* _callback;
Napi::Object* _resource;

void CallBack()
{
  _callback->MakeCallback(*_resource, std::initializer_list<napi_value>{}, *_context);
}

void MakeCallbackWithAsyncContext(const Napi::CallbackInfo& info)
{
  Napi::Function cb = info[0].As<Napi::Function>();
  _callback = new Napi::FunctionReference(Napi::Persistent(cb));
  _callback->SuppressDestruct();

  _resource = new Napi::ObjectReference(Napi::Persistent(env.Global()));
  _resource->SuppressDestruct();

  _context = new Napi::AsyncContext(info.Env(), "async_context_test", _resource->Value());

  // run CallBack() in different thread
}

程序内部崩溃CallBack()。

当通过 kafka-steams 应用程序推送批量数据时，我看到它多次记录以下消息......

WARN org.apache.kafka.streams.state.internals.AbstractRocksDBSegmentedBytesStore - Skipping record for expired segment.

...我希望通过 leftJoin 步骤连接的数据似乎丢失了。

我在实践中看到过这种情况，无论是当我的应用程序关闭一段时间然后重新启动时，或者当我使用类似 app -reset-tool 的东西来尝试让应用程序重新处理过去的数据时。

我能够通过向相隔一小时的两个主题生成 1000 条消息（按顺序排列原始时间戳）来单独重现此行为，然后让 kafka 流为它们选择一个密钥并尝试 leftJoin 这两个重新设置密钥的流。

该复制品的自包含源代码可在https://github.com/mattsheppard/ins14809/blob/main/src/test/java/ins14809/Ins14809Test.java获取

实际的 kafka-streams 拓扑如下所示。

            final StreamsBuilder builder = new StreamsBuilder();
            final KStream<String, String> leftStream = builder.stream(leftTopic);
            final KStream<String, String> rightStream = builder.stream(rightTopic);

            final KStream<String, String> rekeyedLeftStream = leftStream
                    .selectKey((k, v) -> v.substring(0, v.indexOf(":")));

            final KStream<String, String> rekeyedRightStream = rightStream
                    .selectKey((k, v) -> v.substring(0, v.indexOf(":")));

            JoinWindows joinWindow = JoinWindows.of(Duration.ofSeconds(5));

            final KStream<String, String> joined = …

我为节点创建了一个本机插件,一个64位dll,使用该/clr标志编译以访问另一个.net dll.

一切都可以在我的开发盒(Windows 7,64bit)上很好地工作,但是当将整个目录复制到服务器盒(Windows Server 2008 R2,64位,.net 4.0 Client Profile&Extended installed)时,

var myaddon = require('./build/Release/myaddon');

产生以下错误:

module.js:485
  process.dlopen(filename, module.exports);
          ^
Error: The specified module could not be found.
C:\Users\x\build\Release\myaddon.node
    at Object.Module._extensions..node (module.js:485:11)
    at Module.load (module.js:356:32)
    at Function.Module._load (module.js:312:12)
    at Module.require (module.js:362:17)
    at require (module.js:378:17)

我知道它成功找到文件'myaddon.node',因为当我稍微更改require语句指向一个不存在的文件时,它会抱怨一个不同的错误消息.

没有我的require语句,节点启动正常.

为什么错误以及如何解决？

我让以下编译的正则表达式匹配一堆字符串,包括.net(N)和Java(J).通过多次运行,正则表达式1和正则表达式2之间存在一致的差异,无论是在.net还是在Java中:

??????????????????????????????????????????????????????????????????
  #  regex                             N secs   N x  J secs   J x 
??????????????????????????????????????????????????????????????????
  1  ^[^@]+@[^@]+@[^@]+@[^@]+@[^@]+@$    8.10     1    5.67     1 
  2  ^(?:[^@]+@){5}$                    11.07  1.37    6.48  1.14 
??????????????????????????????????????????????????????????????????

可以而且应该正则表达式编译器不能展开并以其他方式将等效构造标准化为最佳表现形式吗？

如果它们"可以而且应该",那么至少可以编写一个正则表达式优化器,它在编译之前修改正则表达式字符串.

使用的代码的关键部分:

.净

// init
regex = new Regex(r, RegexOptions.Compiled | RegexOptions.CultureInvariant);

// test
sw = Stopwatch.Start();
foreach (var s in strs)
  if (regex.isMatch(s))
    matches++;
elapsed = sw.Elapsed;

Java的

// init
pat = Pattern.compile(r);

// test
before = System.currentTimeMillis();
for (String s : strs)
  if (pat.matcher(s).matches())
    matches++; …