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

package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.players.utilityfunction.UF_IWant3Red;
import onetomany.bargainingchipsgame.players.utilityfunction.UF_IWantColorAndQuantity;

/**
 * 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
                try {
                        CoordinationMessage coordinationMessage = new CoordinationMessage();
                        coordinationMessage.f = new UF_IWant3Red();
                        cout.put(coordinationMessage);

                        Thread.sleep(2000);
                        
                        CoordinationMessage coordinationMessage2 = new CoordinationMessage();
                        coordinationMessage2.f = new UF_IWantColorAndQuantity("Green", 7);
                        cout.put(coordinationMessage2);
                        
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
                
        }

}