damithadayananda

package synchronize;

public class MathClass {
    synchronized void printNumbers(int n) throws InterruptedException
    {
            for (int i=1; i<=n;i++){
                System.out.println(Thread.currentThread().getName() + "::" + i);
                Thread.sleep(500);
           }
    }

damithadayananda

package main

import (
	"runtime"
	"fmt"
)

func main() {
	nCPU:=runtime.NumCPU()
	runtime.GOMAXPROCS(nCPU)

damithadayananda

public static void main(string[] args){
  new FixedThreadPoolExecutor();
}

damithadayananda

package taskExecutor;

import java.util.concurrent.TimeUnit;

public class Task implements Runnable {
    private String name;

    public Task(String name){
        this.name = name;
    }

damithadayananda

package taskExecutor;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

public class FixedThreadPoolExecutor {
    public FixedThreadPoolExecutor(){
        ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newFixedThreadPool(4);
        for(int i=0; i<10;i++){
            Task task = new Task("Task" + i);

damithadayananda

@Retention(RetentionPolicy.RUNTIME) 
@Target(ElementType.FIELD) 
public @interface myField { 
public boolean enabled() default true;
}

damithadayananda

@Retention(RetentionPolicy.RUNTIME) 
@Target(ElementType.METHOD) 
public @interface myMethod { 
} 

damithadayananda

@Retention(RetentionPolicy.RUNTIME) 
@Target(ElementType.TYPE) 
public @interface myType { 
public String brokers() default "localhost"; 
public boolean _continue() default false; 
} 

damithadayananda

public class threadWithTheaClass extends Thread { 
public void run(){ 
System.out.println("thread using class"); 
} 
} 

public class main{ 

public static void main(string[] args) 

damithadayananda

public class annonymousClassUsingThreadClass { 
public annonymousClassUsingThreadClass() { 
Thread t = new Thread(){ 
public void run(){ 
System.out.println("anonymous thread"); 
} 
}; 
t.start(); 
} 
}