concurrency

1热度

3回答

我一直在试图让Nhibernate使用字节数组作为版本映射到sql时间戳。我实现了一个 IUserVersionType，但Nhibernate正在数据库中创建varbinary而不是时间戳。受Ayende最近在博客文章并发性的启发，我改变了我的映射，以指定sql-type到时间戳完美运行。然而，我现在面临一个相当好奇的问题其中Nhibernate做插入，获取新版本，然后立即尝试进行更

1热度

4回答

使用没有锁定的writeLock安全吗？

假设这是一个“单例”实现：我保证这只会调用一次productCatalogLoader.load（），并且不会出现任何空指针？任何方法来使这更简单？ private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); private ProductCatalog productCatalog; public Pr

6热度

5回答

Smalltalk中的图像间通信。可能？

我有一个图形遍历问题，这个问题在Smalltalk中精美而优雅地建模，但对于一个小图片图像实例而言它太大（就计算和存储而言）。所以，我想跨多个实例分割问题。我的问题是，是否有任何好的方法发送消息之间的Smalltalk实例。有点像MPI，但是适合smalltalk。我应该提到我在Squeak上，但是如果有这种特性的一些小动作的味道，我可以应付。

4热度

2回答

死你threadpoolexecutor

我有一个java.util.concurrent.Execution服务 - 单线程池执行程序。我向它提交了某些任务。如果任务抛出一个未经检查的异常，线程就会死亡，但服务确保生成一个新线程并执行后续任务。不过，我不想要这个功能，仍然想使用threadPoolExecutor。即如果任务抛出未经检查的异常，我希望服务关闭DownNow（）。达到此目的的最佳方法是什么？使用自定义线程工厂会限制产生的

1热度

2回答

时间受限服务

我正在开发一个应用程序，发出请求的MusicBrainz web服务。我在MusicBrainz的手动阅读不使超过每秒一个请求到web服务或客户机的IP将被阻止。您建议使用哪种体系结构，以便使此限制对服务客户端透明。我想调用一个方法（例如getAlbuns），它只应该在最后一次请求后1秒发出请求。我也想立刻拨打10请求和服务应该处理的排队，返回结果时缴费（非阻塞）。谢谢！

5热度

6回答

如何在java中执行actor（erlang）？

我在Java中处理财务应用程序并获得并发权很痛苦。 Erlang和actors模型应该适合大规模并发应用程序，但我无法弄清楚如何在Java中完成它。我知道有诸如Jetlang，FunctionalJava，kilim等库，但它们通常不会超越简单的例子。假设我需要处理三个或四个不同的事件，例如根据市场数据馈送，订单/交易馈送和“输出”这些数据的某些派生来计算一些数字。大多数情况下，这些事件或数据流需

3热度

1回答

MSSQL中的并发检查（TSEQUAL的替代品）

我正在开发SQL 2008下，但是我有一个SQL 2000数据库（在兼容模式下）。有几个查询正在使用“TSEQUAL”功能做并发检查。但是，似乎SQL 2008中已经完全删除了这个函数，并且这些语句（坐在SPROCS中）不再编译。什么是并发检查的最佳方法在SQL 2005和更高？

1热度

1回答

使用JMeter测试Web应用程序中的并发性和/或事务完整性

我对使用数据库中的多个线程（大部分职业生涯已用于前端）颇为陌生。今天我试着测试了一个简单的php应用程序，我用这个应用程序将数据存储在mysql数据库中，并使用ISAM表模拟了使用Table Locking进行的事务。我刚刚写了一篇博客帖子上的步骤在这里： Testing With JMeter 从我的结果我简单的PHP应用程序似乎保持事务完整性完好（如在我的CSV文件作为数据可见与从数据库I

2热度

2回答

如何创建弹出忙标签的任务，并在执行时取消？

我正在使用swing在java（1.6）中编写应用程序。我目前在JXLayer上有一个JXBusyLabel，作为我的程序的内容区域，用作繁忙指示器。我想提供一种方式让其他人与我一起创建一个任务，在执行时弹出忙标签。问题是，任务必须是可以取消的。公开我想要的功能的最佳方式是什么？一些想法，我想出来的：原始访问setBusy（）这显然是最简单的我，但需要用户知道和了解的Swing线程问题。公

75热度

5回答

如何中断阻塞在take（）上的BlockingQueue？

我有一个类从BlockingQueue采取对象，并通过连续循环呼叫take()来处理它们。在某些时候，我知道没有更多的对象会被添加到队列中。我如何中断take()方法以阻止阻塞？下面是处理的对象的类： public class MyObjHandler implements Runnable { private final BlockingQueue<MyObj> queue;