Skip to content

Instantly share code, notes, and snippets.

@smat
Created February 25, 2015 09:03
Show Gist options
  • Star 1 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save smat/9d76d49f5618c4fd4284 to your computer and use it in GitHub Desktop.
Save smat/9d76d49f5618c4fd4284 to your computer and use it in GitHub Desktop.
Semaphore filter
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.concurrent.Semaphore;
public class SemaphoreFilter implements Filter {
private Semaphore semaphore;
@Override
public void init(FilterConfig filterConfig) throws ServletException {
semaphore = new Semaphore(20);
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
if (semaphore.tryAcquire()) {
try {
filterChain.doFilter(servletRequest, servletResponse);
}
finally {
semaphore.release();
}
}
else {
((HttpServletResponse) servletResponse).sendError(503);
}
}
@Override
public void destroy() {
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment