0MQ:在将上下文传递给线程池时，抛出分段错误

0MQ: on passing a context to a pool of threads a Segmentation fault was thrown

本文关键字：错误 分段 线程 上下文 0MQ      更新时间：2023-10-16

>我正在构建一个小程序(这里)，其中main()向所有工作线程发送相同的msg，工作线程只需打印msg。

我想我已经完全遵循了官方指南中的本教程。

我通过 void 指针将 0MQcontext传递给线程，然后将其投射回zmq::context_t *.但我仍然得到了分段错误。以下是来自 GDB 中的核心转储的信息：

Core was generated by `./test 1'.
Program terminated with signal SIGSEGV, Segmentation fault.
#0  zmq::ctx_t::check_tag (this=this@entry=0xabadcafe) at src/ctx.cpp:89
89  src/ctx.cpp: No such file or directory.
[Current thread is 1 (Thread 0x7fcdaae3f700 (LWP 1428))]
(gdb) bt
#0  zmq::ctx_t::check_tag (this=this@entry=0xabadcafe) at src/ctx.cpp:89
#1  0x00007fcdad17c275 in zmq_socket (ctx_=0xabadcafe, type_=7) at src/zmq.cpp:245
#2  0x0000000000402da1 in zmq::socket_t::init (this=0x7fcdaae3edf0, context_=..., type_=7) at /usr/include/zmq.hpp:649
#3  0x0000000000402ac3 in zmq::socket_t::socket_t (this=0x7fcdaae3edf0, context_=..., type_=7) at /usr/include/zmq.hpp:463
#4  0x0000000000401f18 in task1 (arg=0x170ac20) at test.cpp:21
#5  0x00000000004050fe in std::_Bind_simple<void (*(void*))(void*)>::_M_invoke<0ul>(std::_Index_tuple<0ul>) (this=0x170e0d8)
at /usr/include/c++/5/functional:1531
#6  0x0000000000405008 in std::_Bind_simple<void (*(void*))(void*)>::operator()() (this=0x170e0d8) at /usr/include/c++/5/functional:1520
#7  0x0000000000404f98 in std::thread::_Impl<std::_Bind_simple<void (*(void*))(void*)> >::_M_run() (this=0x170e0c0) at /usr/include/c++/5/thread:115
#8  0x00007fcdacc48c80 in ?? () from /usr/lib/x86_64-linux-gnu/libstdc++.so.6
#9  0x00007fcdacf196ba in start_thread (arg=0x7fcdaae3f700) at pthread_create.c:333
#10 0x00007fcdac6b782d in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:109
(gdb) quit

程序编译与g++ -std=c++11 test.cpp -o test -lzmq -lpthread -g.

在此用例中，无线程Context()可以帮助：

本机 API 建议将这种做法用于基于纯inproc://传输类的多线程使用：

zmq_init()函数初始化 ØMQ 上下文。

io_threads参数指定用于处理 I/O 操作的 ØMQ 线程池的大小。如果应用程序仅对消息传递使用 inproc 传输，则可以将其设置为零，否则至少将其设置为 1。

螺纹安全

ØMQ上下文是线程安全的，可以根据需要在任意数量的应用程序线程之间共享，而无需调用方进行任何额外的锁定。

此函数已被 zmq_ctx_new(3) 弃用。

最近的 { API/c++ 包装器 } 通过实例化后通过Context( NUM_io_threads )将此步骤(最初在 {v2.1.11 API/c++ 包装器 } 中可用)移动到 { v4.2.2 } 拆分进程中，通过安装调用
zmq_ctx_set( *ctx, ZMQ_IO_THREADS, 0 )

int main( int argc, char* argv[] )
{   
int worker_num;
if (  argc != 2 ) { cout << "1 parameter pls" << endl;                           exit(1); } // EXIT[1]
try
{
if ( !has_only_digits( string( argv[1] ) ) ) { cout << "digit pls" << endl;    exit(1); } // EXIT[2]
worker_num =     stoi( string( argv[1] ) );
}
catch ( exception e ) { cout << "exception while processing parameters" << endl; exit(1); } // EXIT[3]
// _______________________________________  // ZeroMQ inproc use-case W/O IO-thread
zmq::context_t context( 0 );             // 
// _______________________________________  // 
zmq::socket_t  distask_socket( context, ZMQ_PUSH );
distask_socket.bind( "inproc://task_publisher" );
vector<thread> pool;
for ( int i = 0; i < worker_num; i++ )
{
cout << "main() : creating thread, " << i << endl;
pool.push_back( thread(           task1,
(void *) &context
)
);
}
for ( int i = 0; i < worker_num; i++ )
{
zmq::message_t msg( 6 );
memcpy( (void *) msg.data(), "World", 6 ); 
distask_socket.send( msg );
}
for ( auto &t : pool )
t.join();
exit(0);
}
值得一提的是，如果挤压最后

一点性能并消除延迟源。

pool.push_back(thread(task1, (void *)context));

应该是

pool.push_back(thread(task1, (void *)&context));

因为你想传递context的地址

相关文章：