source: src/main/java/onetomany/bargainingchipsgame/players/Coordinator.java@ 279

package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.players.utilityfunction.UF_IWant3Red;

/**
 * Coordinates all bilateral threads.
 */
public class Coordinator implements Runnable
{
        // Messaging comin gin and out of the coordinator
        protected BlockingQueue<NegotiationStatusMessage> cin;
        protected BlockingQueue<CoordinationMessage> cout;
        
        public Coordinator(BlockingQueue<NegotiationStatusMessage> negotiationMsg,
                        BlockingQueue<CoordinationMessage> coordinationMsg) 
        {
                cin = negotiationMsg;
                cout = coordinationMsg;
        }

        @Override
        public void run() 
        {
                // Send a very simple coordination message to Bob
                CoordinationMessage coordinationMessage = new CoordinationMessage();
                coordinationMessage.f = new UF_IWant3Red();
                try {
                        cout.put(coordinationMessage);
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
        }

}