How to distribute collection of values to dynamic list?

Question

0.00/5 (No votes)

See more:

I am developing TCP client-server console application. I have N number of clients connected to server. On a server side I need to share M records and each record should be sent only once to client. Each record should be received only by 1 client.
For example number of records N=4 and number of clients M=10 and result should be:
record1 – to client1
record2 – to client2
record3 – to client3
record4 – to client4
record5 – to client1
record6 – to client2
record7 – to client3
record9 – to client4
record10 – to client5

The problem is that the number of records M is fixed, but the number clients N is not fixed (sometimes N=3, sometimes N=5, etc)

Could you please suggest me a solution to organize this type of flow control?

Posted 17-Feb-14 1:29am

x0rn

Add a Solution

2 solutions

Add a Solution

Add your solution here

Treat my content as plain text, not as HTML

Preview 0

…

Existing Members

Sign in to your account

...or Join us

Download, Vote, Comment, Publish.

Your Email
Password
Forgot your password?

Your Email
This email is in use. Do you need your password?
Optional Password

I have read and agree to the Terms of Service and Privacy Policy
Please subscribe me to the CodeProject newsletters

When answering a question please:

Read the question carefully.
Understand that English isn't everyone's first language so be lenient of bad spelling and grammar.
If a question is poorly phrased then either ask for clarification, ignore it, or edit the question and fix the problem. Insults are not welcome.
Don't tell someone to read the manual. Chances are they have and don't get it. Provide an answer or move on to the next question.

Let's work to help developers, not make them feel stupid.

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

Vedat Ozan Oner · Answer 1 · 2014-02-17T01:51:00

my algorithm would be using a queue for clients, and two different threads, one for distributing records and one for collecting results.

distribution:

while(a record exists) {
client = queue.dequeue();
if(client==null) continue;

tracker.add(record, client);
client.send(record);
}

collecting result:

while(listen) {
client=tracker.remove(record);
queue.enqueue(client);
}

- client can register/unregister itself.
- you should also set a timeout value for processing. when timeout, you assume the client has gone, and you should reprocess the record. in that case, again use a queue for records to be processed.

basically, that would be my solution.

x0rn · Answer 2 · 2014-02-17T02:19:00

I'd try to implement something like this:

You'll need one list or collecting holding all clients being connected. You'll need random access, i.e. you'll have to add clients to the front or back and you'll have to be able to remove any element at any time. Bonus points if the list is sorted by number of assigned records (ascending).

When there's a new record to process (or while you iterate over a list with them):

- Send the record to the client being in front of your list.
- Remove the client from the front of the list and add it to the back (unless the list is sorted anyway).
- When a new client connects, it's added to the front of your list.

If a client disconnects, it's removed from the list and the records are readded for redistribution.
If I didn't make any mistake while thinking about this, this should ensure that always one of the clients with the least number of tasks will get a new record unless many clients drop mid-processing. In that case a sorted list would be an advantage.

Of course, there's room for optimization and it's not the best strategy if your number of clients doesn't change while processing (and only before you start doing so). In this case you could simply determine the client that's supposed to process record n using i = n % number_of_clients.

http://stackoverflow.com/questions/21829187/how-to-distribute-collection-of-values-to-dynamic-list[^]

How to distribute collection of values to dynamic list?

2 solutions

Solution 1

Solution 2

Add your solution here

Preview 0