Blackhen Threading Library
I am looking for documentation for the Blackhen threading library and am unable to find any. I have just found one article here. Can someone please point me to some documention for this library? ...
queue
Python 2.6 send connection object over Queue / Pipe / etc.
Given this bug (Python Issue 4892) that gives rise to the following error: >>> import multiprocessing >>> multiprocessing.allow_connection_pickling() >>> q = multiprocessing.Queue() >>> p = multiprocessing.Pipe() >>> q.put(p) >>> q.get() Traceback (most recent call last): File "<stdin>", line 1, in <module> File "/.../python2.6/...
Which queue is most appropriate?
I'm building a mobile photo sharing site in Python similar to TwitPic and have been exploring various queues to handle the image processing. I've looked into RabbitMQ and ActiveMQ but I'm thinking that there is a better solution for my use case. I'm looking for something a little more lightweight. I'm open to any suggestions. ...
Threadpool in IIS context
Hi. I have a general question about System.Threading.Threadpool when run in a webapplication on IIS. Say we have 2 requests execute at once, and we fire up a couple of threads through the ThreadPool.QueueUserWorkItem method. Will the two requests share the ThreadPool, or will the calls to the ThreadPool from the two requests operate in...
C# Queue problem
Suppose I have a class XYNode { protected int mX; protected int mY; } and a queue Queue<XyNode> testQueue = new Queue<XYNode>(); I want to check if a node with that specific x and y coordinate is already in the queue. The following obviously doesn't work : testQueue.Contains(new XYNode(testX, testY)) because even if a no...
AudioQueueStart reporting unsupported format
I'm trying to get audio queue working on an iphone app, and whenever AudioQueueStart is called it gives the "fmt?" result code (kAudioFormatUnsupportedDataFormatError). In the code below i'm setting the format to kAudioFormatLinearPCM, which surely is supported. What am i doing wrong? data.mDataFormat.mSampleRate = 44100; data.mDataForm...
display of duplicate records in firefox
hi I am working on an online music store. There are buttons like myplaylists, mydownloads etc... On clicking on these buttons, a list of songs appears accordingly in a grid view. The problem is that when i click on the buttons twice quickly the list appears two times like 1..4..8 1..4..8 and if i click thrice quickly it happens three ti...
queuing solution to process a record through multiple processes
The application is on .Net 3.5 and Oracle Standard Edition 11G database where a table have over 2 million records. The record size is not huge. The records have a Status column of type Char(1). Depending upon the status a process picks records to process and updates the status after completion. A record goes via multiple processes in ser...
Best method for saving values of a queue in case of program failure
Say I have a multithreaded application made up of two separate threads and a Queue. Thread 1 finishes it's computation and puts the result in the Queue. Meanwhile thread 2 is constantly looping and checking if there is any data in the Queue for it to process. How can I save the values in the queue to disk temporarily in case the for so...
not exactly fifo
I'm busting my head but cannot find a solution for this. Please consider this scenario: I have writers that want to write to non-blocking "queue" to another machine on the local network and have a reader that will read data (blocking mode if there are no writers) and do some job A and then return after a long hour and take next data. ...
Dynamics CRM v4 monitor mailbox for a queue
Hi I want to set up Microsoft Dynamics CRM to monitor a single mailbox using pop3 and then have any mails in that mailbox added as email activities to a queue in CRM. I have set up the pop3 mail box and I know that it works. I have set up the email router with an incoming profile for the mailbox. I have a queue called "inbound" in CRM...
Python Queue - yet another question
Hi, I am reading up on how to utilize Python Queues to send and receive short messages between nodes. I am simulating a set of nodes that are in a nice tree structure. I want some of these nodes to send a fixed-size data to its parent. Once this parent receives data from some of its child-nodes, it will "process" it and send a "aggr...
Removing from STL std::queue without destructing the removed object?
All the documentation I can find on the STL containers (both queue and list) say that for any of the remove functions the removed object's destructor is called. This means that I can't use std::queue any time I want a queue that's simply a list of objects needing some operation performed on them. I want to be able to add objects to the...
Does C++ have standard queue?
I know that there's a standard library vector in C++. Is there a queue? An online search suggests there might be, but there's not much about it if there is one. Edit: All right. Thanks a ton guys. ...
Is there a pattern for this queueing system, and example Java code?
I have a component that I wish to write and it's the kind of thing that feels like a common pattern. I was hoping to find the common name for the pattern if there is one, and examples of how to go about implementing it. I have a service that queues requests and processes them one at a time. I have a number of client threads which make t...
Dumping a multiprocessing.Queue into a list
I wish to dump a multiprcoessing.Queue into a list. For that task I've written the following function: import Queue def dump_queue(queue): """ Empties all pending items in a queue and returns them in a list. """ result = [] # START DEBUG CODE initial_size = queue.qsize() print("Queue has %s items initially....
Accessing a Queue from standalone code
I have a Queue configured in the Rational Application Developer for WebSphere, using a "V5 default messaging provider" and a Websphere6.1 I now try to access it using a standalone app (JUnit Test), in order to put some messages in it. I currently use the following code: Hashtable env = new Hashtable(); env.put(Context.INITIAL_CONTE...
Is Queue.Peek thread safe?
A read operation on a 32 bit field is atomic. So if the queue holds object references the Queue.Peek method should be thread safe, right? ...
Add timeout argument to python's Queue.join()
I want to be able to join() the Queue class but timeouting after some time if the call hasn't returned yet. What is the best way to do it? Is it possible to do it by subclassing queue\using metaclass? ...
concurrent queue - general question (description and usage)
Hello, I am having some trouble grasping the idea of a concurrent queue. I understand a queue is a FIFO, or first come first serve, data structure. Now when we add the concurrency part, which I interpret as thread safety (please let me know if that is incorrect) things get a bit fuzzy. By concurrency we mean the way various threads can...