Tag: multithreading

如何限制Python中函数调用的执行时间: 在我的代码中有一个与套接字相关的函数调用，那个函数来自另一个模块，因此不在我的控制之下，问题是它偶尔会阻塞几个小时，这是完全不可接受的，我怎样才能限制我的代码中的函数执行时间？我想解决scheme必须利用另一个线程。

在Linux中未定义的对pthread_create的引用: 我从https://computing.llnl.gov/tutorials/pthreads/下载了以下演示。 #include <pthread.h> #include <stdio.h> #define NUM_THREADS 5 void *PrintHello(void *threadid) { long tid; tid = (long)threadid; printf("Hello World! It's me, thread #%ld!\n", tid); pthread_exit(NULL); } int main (int argc, char *argv[]) { pthread_t threads[NUM_THREADS]; int rc; long t; for(t=0; t<NUM_THREADS; t++){ printf("In main: creating thread %ld\n", t); rc = pthread_create(&threads[t], NULL, PrintHello, (void *)t); […]

C ++线程的简单例子: 有人可以发布一个简单的例子，在C ++中启动两个（面向对象）线程。我正在寻找实际的C ++线程对象，我可以扩展运行方法（或类似的东西），而不是调用一个C风格的线程库。更新 – 我遗漏了任何操作系统特定的请求，希望谁回复谁会回答跨平台库使用。我只是现在就明确表示。

num ++可以是'int num'的primefaces吗？: 通常，对于int num ， num++ （或++num ）作为读取 – 修改 – 写入操作是不primefaces的。但是我经常看到编译器，比如GCC ，为它生成下面的代码（试试这里）：由于对应于num++第5行是一条指令，所以在这种情况下，我们可以得出结论： num++ 是primefaces吗？如果是这样，这是否意味着这样生成的num++可以在并发（multithreading）的情况下使用，没有任何数据竞争的危险（即，我们不需要，例如， std::atomic<int>并强加相关的成本，因为它primefaces无论如何）？ UPDATE 请注意，这个问题并不是增量是否是primefaces的（这不是，而且是问题的开场白线）。这是否可以在特定情况下，即在某些情况下是否可以利用单指令性质来避免lock前缀的开销。而且，正如接受的答案中提到的关于单处理机的部分，以及这个答案，在它的评论和其他人的谈话中解释，它可以（但不是用C或C ++）。

java.lang.OutOfMemoryError：Java堆空间: 我正在执行multithreading程序时出现以下错误 java.lang.OutOfMemoryError: Java heap space 上述错误发生在其中一个线程中。根据我的知识，堆空间仅由实例variables占用。如果这是正确的，那么为什么这个错误在运行正常之后发生，因为在创build对象时分配了实例variables的空间。有没有办法增加堆空间？我应该对我的程序做些什么改变，以便占用更less的堆空间？

什么时候使用multithreadingvolatile？: 如果有两个线程访问一个全局variables，那么很多教程都会说variables是volatile的，以防止编译器将这个variablescaching在一个寄存器中，从而不能正确更新。然而，两个线程都访问一个共享variables是通过互斥体来保护的东西，不是吗？但是在这种情况下，在线程locking和释放互斥体之间，代码是在一个只有一个线程可以访问variables的关键部分，在这种情况下，variables不需要是易失性的？那么在multithreading程序中volatile的用途和用途是什么呢？

在ArrayBlockingQueue中，为什么要将最终成员字段复制到本地最终variables？: 在ArrayBlockingQueue ，所有需要锁的方法在调用lock()之前将其复制到本地finalvariables中。 public boolean offer(E e) { if (e == null) throw new NullPointerException(); final ReentrantLock lock = this.lock; lock.lock(); try { if (count == items.length) return false; else { insert(e); return true; } } finally { lock.unlock(); } } 当字段this.lock是final时候，是否有任何理由将this.lock复制到局部variableslock final ？此外，它还在使用E[]之前使用本地副本： private E extract() { final E[] items = this.items; E x […]

如何在Qt，GCD风格的给定线程中执行函数或lambda？: 在带GCD的ObjC中，有一种方法可以在任何旋转事件循环的线程中执行lambda。例如： dispatch_sync(dispatch_get_main_queue(), ^{ /* do sth */ }); 要么： dispatch_async(dispatch_get_main_queue(), ^{ /* do sth */ }); 它在主线程的队列中执行某些操作（相当于C ++中的[]{ /* do sth */ } ），可以是阻塞的，也可以是asynchronous的。我怎样才能在Qt中做同样的事情？从我读过的内容来看，我想这个解决scheme会以某种方式向主线程的某个对象发送一个信号。但是什么对象？只是QApplication::instance() ？（那是生活在主线程中的唯一对象）。什么信号？从目前的答案和我目前的研究，我似乎真的需要一些虚拟对象坐在主线程与一些插槽，只是等待一些代码执行。所以我决定QApplication 。我目前的代码，这是行不通的（但也许你可以帮助）： #include <QApplication> #include <QThread> #include <QMetaMethod> #include <functional> #include <assert.h> class App : public QApplication { Q_OBJECT public: App(); signals: […]

易变与联锁与locking: 假设一个类有一个public int counter字段，可以被多个线程访问。这个int只是递增或递减。为了增加这个领域，应该使用哪种方法，为什么？ lock(this.locker) this.counter++; ， Interlocked.Increment(ref this.counter); ，将counter的访问修饰符更改为public volatile 。现在我发现了volatile ，我一直在删除许多lock语句和Interlocked的使用。但有没有这样做的理由？