Tag: multithreading

在WinRT的UI线程上运行代码

如何在WinRT（Windows 8 Metro）的UI线程上运行代码？ Invoke方法不存在。

线程安全单例类

我写了一个下面的Singleton类。 我不确定这是否是线程安全的单例类？ public class CassandraAstyanaxConnection { private static CassandraAstyanaxConnection _instance; private AstyanaxContext<Keyspace> context; private Keyspace keyspace; private ColumnFamily<String, String> emp_cf; public static synchronized CassandraAstyanaxConnection getInstance() { if (_instance == null) { _instance = new CassandraAstyanaxConnection(); } return _instance; } /** * Creating Cassandra connection using Astyanax client * */ private CassandraAstyanaxConnection() { context = new […]

C＃中的multithreading启animation面？

我想要一个启animation面显示，而应用程序正在加载。 我有一个与系统托盘控制绑定的表单。 我希望在加载这个表单时显示启animation面，这需要一些时间，因为它正在访问一个Web服务API来填充一些下拉菜单。 我也想在加载前做一些基本的依赖性testing（也就是说，Web服务可用，configuration文件是可读的）。 随着启动的每个阶段，我想要更新启animation面的进展。 我一直在阅读很多关于线程的知识，但是我正在迷失于从main（）方法来控制的地方？）。 我也缺less如何Application.Run()作品，这是应该从哪个线程创build？ 现在，如果系统托盘控制的表单是“活”的forms，那么应该从哪里来？ 无论如何，它不会加载，直到表单完成？ 我不是在寻找代码讲义，更多的是algorithm/方法，所以我可以一劳永逸的了解这一点:)

C ++ 11引入了标准化的内存模型。 这是什么意思？ 那么如何影响C ++编程呢？

C ++ 11引入了标准化的内存模型，但究竟是什么意思呢？ 那么如何影响C ++编程呢？ 香草萨特在这里说， 内存模型意味着C ++代码现在有一个标准化的库来调用，不pipe编译器是谁做的，在哪个平台上运行。 有一个标准的方法来控制不同的线程如何与处理器的内存交谈。 Sutter说：“当你谈论的是跨标准的不同核心进行拆分时，我们正在谈论内存模型。我们将会优化它，而不会破坏人们在代码中所做的下列假设。 那么，我可以记住这个在线类似的段落（因为我已经有自己的记忆模型，自诞生以来：P），甚至可以回答别人提出的问题，但说实话，我不完全明白这一点。 所以，我基本上想知道的是，C ++程序员甚至在之前就开发了multithreading应用程序，所以如果是POSIX线程，Windows线程或者C ++ 11线程，它又有什么关系呢？ 有什么好处？ 我想了解低级细节。 我也感觉到C ++ 11内存模型与C ++ 11multithreading支持有某种联系，因为我经常将这两者结合在一起。 如果是这样，究竟是如何？ 他们为什么要相关？ 因为我不知道multithreading的内部工作原理，以及一般的内存模型意味着什么，所以请帮助我理解这些概念。 🙂

在Java中某些指定的时间限制之后终止线程

是否有一种方法来杀死一个在Java中的指定时间限制之后的子线程？ 编辑：此特定的线程可能会在最坏的情况下被阻塞（线程用于等待文件修改，并阻塞，直到这个事件发生），所以我不知道中断（）会成功？

比较使用Thread.Sleep和Timer来延迟执行

我有一个方法应该延迟运行一段指定的时间。 我应该使用 Thread thread = new Thread(() => { Thread.Sleep(millisecond); action(); }); thread.IsBackground = true; thread.Start(); 要么 Timer timer = new Timer(o => action(), null, millisecond, -1); 我读过一些关于使用Thread.Sleep的文章是糟糕的devise。 但我不明白为什么。 但是对于使用Timer，Timer的configuration方法。 由于执行延迟，我不知道如何configurationTimer。 你有什么build议吗？ 或者，如果您有延迟执行的替代代码也很感激。 谢谢，

我可以使用线程在IIS上执行长时间运行的作业吗？

在ASP.Net应用程序中，用户单击网页上的button，然后通过事件处理程序在服务器上实例化一个对象，并在该对象上调用一个方法。 该方法去外部系统做东西，这可能需要一段时间。 所以，我想要做的是在另一个线程中运行该方法调用，所以我可以通过“您的请求已被提交”返回控制权给用户。 我相当高兴能够做到这一点，但是如果用户可以继续查询对象的状态，那将会更好。 我不知道的是，如果IIS允许我的线程继续运行，即使用户会话过期。 试想一下，用户触发事件，并在服务器上实例化对象，并在新线程中激发该方法。 用户对“您的请求已被提交”消息感到满意，并closures浏览器。 最终，这个用户会话将在IIS上超时，但该线程可能仍在运行，正在工作。 IIS允许线程继续运行，还是会在用户会话过期后将其终止并丢弃对象？ 编辑：从答案和评论，我明白，这样做的最好方法是移动IIS以外的长时间运行的处理。 除此之外，这涉及到应用程序的回收问题。 实际上，我需要在有限的时间内使版本1开始工作，并且必须在现有的框架内部工作，所以想要避免服务层，因此希望仅仅在IIS内部启动线程。 实际上，这里的“长时间运行”只有几分钟的时间，网站上的并发性会比较低，所以应该没问题。 但是，下一个版本肯定需要分解成一个单独的服务层。

如何从线程捕获exception

我有Java的主类，在类中，我开始一个新的线程，在主要的，它等待，直到线程死亡。 在某些时候，我从线程抛出一个运行时exception，但是我无法捕捉到主类中的线程抛出的exception。 这里是代码： public class Test extends Thread { public static void main(String[] args) throws InterruptedException { Test t = new Test(); try { t.start(); t.join(); } catch(RuntimeException e) { System.out.println("** RuntimeException from main"); } System.out.println("Main stoped"); } @Override public void run() { try { while(true) { System.out.println("** Started"); sleep(2000); throw new RuntimeException("exception from thread"); […]

最佳实践：定位更改期间的AsyncTask

AsyncTask在另一个线程中运行复杂的任务是一件好事。 但是，当AsyncTask仍在运行时，如果有方向更改或其他configuration更改，则当前的Activity被销毁并重新启动。 而AsyncTask的实例连接到该活动，它失败，并导致“强制closures”消息窗口。 所以，我正在寻找某种“最佳实践”来避免这些错误，并防止AsyncTask失败。 我目前看到的是： 禁用方向更改（当然不是你应该处理的方式）。 让任务生存并通过onRetainNonConfigurationInstance通过新的活动实例进行onRetainNonConfigurationInstance 只要在Activity被销毁时取消任务，并在Activity重新创build时重新启动它。 将任务绑定到应用程序类而不是活动实例。 在“货架”项目中使用的一些方法（通过onRestoreInstanceState） 一些代码示例： 屏幕旋转期间的Android AsyncTasks，第I 部分和第II部分 ShelvesActivity.java 你能帮我find最好的解决问题的办法，并且容易实施吗？ 代码本身也很重要，因为我不知道如何正确解决这个问题。

multithreadingPython应用程序和套接字连接的问题

我正在研究一个运行在具有4G内存的Ubuntu机器上的Python应用程序的问题。 该工具将被用于审计服务器（我们更喜欢滚动我们自己的工具）。 它使用线程连接到许多服务器，许多TCP连接失败。 但是，如果我在启动每个线程之间添加1秒的延迟，则大多数连接都会成功。 我已经使用这个简单的脚本来调查可能发生的事情： #!/usr/bin/python import sys import socket import threading import time class Scanner(threading.Thread): def __init__(self, host, port): threading.Thread.__init__(self) self.host = host self.port = port self.status = "" def run(self): self.sk = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.sk.settimeout(20) try: self.sk.connect((self.host, self.port)) except Exception, err: self.status = str(err) else: self.status = "connected" finally: self.sk.close() def get_hostnames_list(filename): return […]