Nxt$2.java

import java.util.concurrent.ThreadLocalRandom;

class Nxt$2
  implements Runnable
{
  Nxt$2(Nxt paramNxt) {}
  
  public void run()
  {
    try
    {
      if (Nxt.Peer.getNumberOfConnectedPublicPeers() < Nxt.maxNumberOfConnectedPublicPeers)
      {
        Nxt.Peer peer = Nxt.Peer.getAnyPeer(ThreadLocalRandom.current().nextInt(2) == 0 ? 0 : 2, false);
        if (peer != null) {
          peer.connect();
        }
      }
    }
    catch (Exception e)
    {
      Nxt.logDebugMessage("Error connecting to peer", e);
    }
    catch (Throwable t)