GorvGoyl

using System;

    public class Publisher //main publisher class which will invoke methods of all subscriber classes
    {
        public delegate void TickHandler(Publisher m, EventArgs e); //declaring a delegate
        public TickHandler Tick;     //creating an object of delegate
        public EventArgs e = null;   //set 2nd paramter empty
        public void Start()     //starting point of thread
        {
            while (true)

GorvGoyl

import java.util.concurrent.Semaphore;

class Queue {
  int value;

  static Semaphore semProd = new Semaphore(1); //Producer is first getting lock on producer semaphore
  
  static Semaphore semCon = new Semaphore(0);
  

GorvGoyl

import java.util.concurrent.*;

class Producer implements Runnable {
 
    private BlockingQueue<Integer> queue;
     
    Producer(BlockingQueue<Integer> q){
        this.queue=q;
    }
    

GorvGoyl

import java.util.*;

public class InterThreadCommunicationExample {

    public static void main(String args[]) {

        final LinkedList<Integer> sharedQ = new LinkedList<Integer>();

        Thread producer = new Producer(sharedQ);
        Thread consumer = new Consumer(sharedQ);